Artemis cluster and message acknowledgement

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Artemis cluster and message acknowledgement

gkocur
Hello,

I have a newbie question.
I'm playing with artemis clustering, and have simple setup like this:

pruducer----artemis-server1----consumer1
                  |
                  artemis-server2----consumer2

Messages are balanced to server2 exactly as described in documentation. The
only issue I have with this setup is message acknowledgement - "Message
count" for queue
"$.artemis.internal.sf.ersules.f2a284aa-9c3b-11e7-96f2-062013112720" (so
sent to server2) is growing, and "Messages acknowledged" is always 0. Is it
expected behaviour? Or do I miss some configuration?

Thank you for any help with this.

--
Grzegorz



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Reply | Threaded
Open this post in threaded view
|

Re: Artemis cluster and message acknowledgement

Justin Bertram
Queues named like "$.artemis.internal.sf." are internal queues used to move
messages between nodes for things like server-side message load-balancing
or message redistribution.  As long as the cluster is formed properly then
messages should not accumulate there but should land there for just a
moment before they are moved across the cluster bridge to the other node.
I would expect the "Messages Added" stat to go up, but I would expect the
"Message Count" to stay close to 0.

Are you seeing any functional impact?


Justin

On Thu, Sep 21, 2017 at 6:03 AM, gkocur <[hidden email]>
wrote:

> Hello,
>
> I have a newbie question.
> I'm playing with artemis clustering, and have simple setup like this:
>
> pruducer----artemis-server1----consumer1
>                   |
>                   artemis-server2----consumer2
>
> Messages are balanced to server2 exactly as described in documentation. The
> only issue I have with this setup is message acknowledgement - "Message
> count" for queue
> "$.artemis.internal.sf.ersules.f2a284aa-9c3b-11e7-96f2-062013112720" (so
> sent to server2) is growing, and "Messages acknowledged" is always 0. Is it
> expected behaviour? Or do I miss some configuration?
>
> Thank you for any help with this.
>
> --
> Grzegorz
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>
Reply | Threaded
Open this post in threaded view
|

Re: Artemis cluster and message acknowledgement

gkocur
Thank you for your reply.
What you described is exactly what I was expecting - current message count
close to 0.
I can see the number of journal files is growing, so sooner or later I'll be
out of disk space.
The cluster configuration is pretty simple - it's symmetric cluster with
static configuration.
Cluster config on server1:

     <cluster-connections>
         <cluster-connection name="my-cluster">
            <connector-ref>amqp-broker-0</connector-ref>
            <retry-interval>500</retry-interval>
            <use-duplicate-detection>true</use-duplicate-detection>
            <message-load-balancing>ON_DEMAND</message-load-balancing>
            <max-hops>1</max-hops>
            <static-connectors>
               <connector-ref>amqp-broker-1</connector-ref>
            </static-connectors>
         </cluster-connection>
      </cluster-connections>

Cluster config on server2:

      <cluster-connections>
         <cluster-connection name="my-cluster">
            <connector-ref>amqp-broker-1</connector-ref>
            <retry-interval>500</retry-interval>
            <use-duplicate-detection>true</use-duplicate-detection>
            <message-load-balancing>ON_DEMAND</message-load-balancing>
            <max-hops>1</max-hops>
            <static-connectors>
               <connector-ref>amqp-broker-0</connector-ref>
            </static-connectors>
         </cluster-connection>
      </cluster-connections>


Is it ok?


Justin Bertram wrote

> Queues named like "$.artemis.internal.sf." are internal queues used to
> move
> messages between nodes for things like server-side message load-balancing
> or message redistribution.  As long as the cluster is formed properly then
> messages should not accumulate there but should land there for just a
> moment before they are moved across the cluster bridge to the other node.
> I would expect the "Messages Added" stat to go up, but I would expect the
> "Message Count" to stay close to 0.
>
> Are you seeing any functional impact?
>
>
> Justin
>
> On Thu, Sep 21, 2017 at 6:03 AM, gkocur &lt;

> grzegorz.kocur@

> &gt;
> wrote:
>
>> Hello,
>>
>> I have a newbie question.
>> I'm playing with artemis clustering, and have simple setup like this:
>>
>> pruducer----artemis-server1----consumer1
>>                   |
>>                   artemis-server2----consumer2
>>
>> Messages are balanced to server2 exactly as described in documentation.
>> The
>> only issue I have with this setup is message acknowledgement - "Message
>> count" for queue
>> "$.artemis.internal.sf.ersules.f2a284aa-9c3b-11e7-96f2-062013112720" (so
>> sent to server2) is growing, and "Messages acknowledged" is always 0. Is
>> it
>> expected behaviour? Or do I miss some configuration?
>>
>> Thank you for any help with this.
>>
>> --
>> Grzegorz
>>
>>
>>
>> --
>> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
>> f2341805.html
>>





--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Reply | Threaded
Open this post in threaded view
|

Re: Artemis cluster and message acknowledgement

Justin Bertram
Your configuration looks OK to me.  Do you have a reproducible test-case
for this scenario?


Justin

On Fri, Sep 22, 2017 at 3:24 AM, gkocur <[hidden email]>
wrote:

> Thank you for your reply.
> What you described is exactly what I was expecting - current message count
> close to 0.
> I can see the number of journal files is growing, so sooner or later I'll
> be
> out of disk space.
> The cluster configuration is pretty simple - it's symmetric cluster with
> static configuration.
> Cluster config on server1:
>
>      <cluster-connections>
>          <cluster-connection name="my-cluster">
>             <connector-ref>amqp-broker-0</connector-ref>
>             <retry-interval>500</retry-interval>
>             <use-duplicate-detection>true</use-duplicate-detection>
>             <message-load-balancing>ON_DEMAND</message-load-balancing>
>             <max-hops>1</max-hops>
>             <static-connectors>
>                <connector-ref>amqp-broker-1</connector-ref>
>             </static-connectors>
>          </cluster-connection>
>       </cluster-connections>
>
> Cluster config on server2:
>
>       <cluster-connections>
>          <cluster-connection name="my-cluster">
>             <connector-ref>amqp-broker-1</connector-ref>
>             <retry-interval>500</retry-interval>
>             <use-duplicate-detection>true</use-duplicate-detection>
>             <message-load-balancing>ON_DEMAND</message-load-balancing>
>             <max-hops>1</max-hops>
>             <static-connectors>
>                <connector-ref>amqp-broker-0</connector-ref>
>             </static-connectors>
>          </cluster-connection>
>       </cluster-connections>
>
>
> Is it ok?
>
>
> Justin Bertram wrote
> > Queues named like "$.artemis.internal.sf." are internal queues used to
> > move
> > messages between nodes for things like server-side message load-balancing
> > or message redistribution.  As long as the cluster is formed properly
> then
> > messages should not accumulate there but should land there for just a
> > moment before they are moved across the cluster bridge to the other node.
> > I would expect the "Messages Added" stat to go up, but I would expect the
> > "Message Count" to stay close to 0.
> >
> > Are you seeing any functional impact?
> >
> >
> > Justin
> >
> > On Thu, Sep 21, 2017 at 6:03 AM, gkocur &lt;
>
> > grzegorz.kocur@
>
> > &gt;
> > wrote:
> >
> >> Hello,
> >>
> >> I have a newbie question.
> >> I'm playing with artemis clustering, and have simple setup like this:
> >>
> >> pruducer----artemis-server1----consumer1
> >>                   |
> >>                   artemis-server2----consumer2
> >>
> >> Messages are balanced to server2 exactly as described in documentation.
> >> The
> >> only issue I have with this setup is message acknowledgement - "Message
> >> count" for queue
> >> "$.artemis.internal.sf.ersules.f2a284aa-9c3b-11e7-96f2-062013112720"
> (so
> >> sent to server2) is growing, and "Messages acknowledged" is always 0. Is
> >> it
> >> expected behaviour? Or do I miss some configuration?
> >>
> >> Thank you for any help with this.
> >>
> >> --
> >> Grzegorz
> >>
> >>
> >>
> >> --
> >> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> >> f2341805.html
> >>
>
>
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>