Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Date: Thu, 16 Nov 2017 05:34:26 -0700 (MST)
From: alisu <alisu7008@gmail.com>
To: users@activemq.apache.org
Message-ID: <1510835666132-0.post@n4.nabble.com>
Subject: Re-ordering of messages - Artemis
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable
archived-at: Thu, 16 Nov 2017 17:04:01 -0000

In my use case, I have to run two instances of the same application that re=
ad
messages from 'queue-1' and write them back to another queue 'queue-2'.=C2=
=A0 I
need my messages inside the two queues to be ordered by specific property
(sequence number) which is initially added to every message by producer. As
per documentation, inside queue-1 the order of messages will be preserved a=
s
messages are sent by a single producer. But because of having multiple
consumers that read, process and send the processed messages to queue-2, th=
e
order of messages inside queue-2 might be lost. So my task is to make sure
that messages are delivered to queue-2 in the same order as they were read
from queue-1. I have implemented re-sequencer pattern from Apache camel to
re-order messages inside queue-2. The re-sequencer works fine but results t=
o
data transfer overhead as the camel routes run locally. Thinking about doin=
g
it in a better way, I have three questions:

1) Does artemis supports re-ordering of messages inside a queue using a
property such as sequence number.

2) Is it possible to run the routes inside the server? If yes, can you give
an example or give a link to the documentation?

3) Some artemis features such as divert (split) requires modifying broker
configuration (broker.xml file), is there a way to do them programatically
and dynamically so I can decide when to start diverting message? I know thi=
s
can be accomplished by using camel, but I want everything to be running in
the server.

Thanks.


--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.htm=
l