The reference counting is done in AbstractServerMessageImpl.java. In
general instances of ServerMessage should not be passed around, rather a
MessageReference (obtained by calling newReference(..) on the message
object. Then if the message is no longer required in that context,
release() can be c
Ok then I missed something.
Whan/Where is the reference-counting you were talking about in your first mail
happening?
Olivier
-Original Message-
From: Rob Godfrey
Sent: lundi 17 septembre 2018 14:05
To: users@qpid.apache.org
Subject: Re: [Broker-J] JDBC message store performance
Hi Ol
Hi Olivier,
the approach you are attempting will not work for the reasons I described
previously. If the message has (for instance) been placed in two durable
subscription queues (because there are two durable subscriptions) then as
soon as the message is consumed from the first queue it would be
On 17/09/18 10:52, VERMEULEN Olivier wrote:
Hello,
Our messaging topology uses a dispatch-router in front of a bunch of brokers
(the Java one).
Note that we never use the dispatch-router for direct communication between a
producer and a consumer, everything goes through a broker.
Now when we t
Hello,
Our messaging topology uses a dispatch-router in front of a bunch of brokers
(the Java one).
Note that we never use the dispatch-router for direct communication between a
producer and a consumer, everything goes through a broker.
Now when we try to send a message, through the dispatch-rou
Hello Rob,
Thanks for the answer.
I started looking at the code to see if there is something I can do about these
2 commits.
But before going any further I'd like your input on the below, to see if what
I'm trying to do could work or if I'm missing something (which I'm surely are)
https://github
