Confirm that step by step. Are the messages still on the broker when the
transaction rolls back? Are they still on the broker when the client
disconnects? Wherever you lose them, the previous step is the one to
investigate.
I'm not sure why there are no messages in the Queue. If there were
messages on the queue and not acknowledged they should still be there when
you close the consumer. So I would expect them to be available on
reconnect.
On Thu, Jun 11, 2015 at 4:48 AM, spamtrap <
nospam.1.friedbad...@spamgourmet.
I have finally manage to make it work.
Added following to my context file.
Then READ: Collection queues = brokerQuery.getQueues();
for (QueueViewMBean queueViewMBean : queues) {
@SuppressWarnings("unchecked")
List browseMessag
So I think I understand that you want to do performance profiling to
understand how long it takes to run the message handler (which you wrote)
for each message your consumer processes. Is that accurate?
If so, there are many profilers available; this article (
https://blog.idrsolutions.com/2014/0
The alternate approach I described would probably be taken from outside the
broker rather than from a broker plugin. But the method Chris pointed out
to you seems like a good one for implementing this within a plugin.
On Jun 11, 2015 5:46 AM, "Christopher Shannon" <
christopher.l.shan...@gmail.com
The ManagedRegionBroker keeps track of subscriptions. Inside that broker
class it keeps track of queueSubscribers and topicSubscribers. The maps
store SubscriptionView objects and they have a method called
getMessageCountAwaitingAcknowledgement() that you could use.
ManagedRegionBroker will be o
Hi,
I am not sure what to do when you say "using JMX to iterate over each
subscription", Where will you do this inside a broker plugin? do you mean to
create jmx connection and get those stats?
Can we not access those stats directly inside a broker plugin?
Thanks,
Abhi
--
View this message in
On Wed, 10 Jun 2015 12:32:00 -0400, Christopher Shannon
wrote:
OK. I've tried this. However when I create the new consumer object,
nothing is consumed and I notice that there are no messages in the
queue to consume.
Any ideas why this is happening?
>Yes you should create a new consumer object
