Greetings,
I'm a new sub and searched far a wide (including archives) for this but am
not hitting...
Scenario is pretty simple setup:
all localhost - consumer (nodejs) and broker (standalone 5.8.0)
A separate producer loaded up about 6000 message, all around 250K each into
a persistent queue
Day 1: in the web console, the number of messages 6192 and browsing there
shows a large number of them on the page...all looks good
Day 2: run a node client to retrieve messages using stomp protocol with
auto ack. Messages spew out to their own instance of a function handler at
a high rate... 400 messages in a very short time before I stop the client
Day 3: change the ack to client-individual and try to patch the client code
to ack (OG code overlooks that) and run a test... 3 messages are delivered
and delivery stops. I figured my code patch the nodejs library sukt and
kill the client.
But the console also only gets delivered 3 messages. I can delete one and
another takes its place.
Restarting activemq (and jetty) does not change anything: always just three.
I set no prefetch limits ... Default prefetch is 1000 afaik so that appears
to not be it.
I want to understand what is happening and use the goal of returning to
they way it was on Day 2 to do that.
Persistent sessions? What is going on here?
Regards
Logs for web console listing of queue contents:
2015-02-02 14:27:18,333 | DEBUG | localhost adding consumer:
ID:blah-53146-1422915407996-3:
1:1:2 for destination: queue://deltas_cmsapi |
org.apache.activemq.broker.region.AbstractRegion | ActiveMQ VMTransport:
vm://localhost#1-2
2015-02-02 14:27:18,336 | DEBUG | queue://deltas_cmsapi add sub:
QueueBrowserSubscription: consumer=ID:blah-53146-1422915407996-3:1:1:2,
destinations=0, dispatched=0, delivered=0, pending=0, dequeues: 0,
dispatched: 3, inflight: 0 | org.apache.activemq.broker.region.Queue |
ActiveMQ VMTransport: vm://localhost#1-2
2015-02-02 14:27:18,337 | DEBUG | deltas_cmsapi toPageIn: 200, Inflight: 0,
pagedInMessages.size 3, enqueueCount: 0, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost]
Task-5
2015-02-02 14:27:18,338 | DEBUG | dispatch to browser:
QueueBrowserSubscription: consumer=ID:blah-53146-1422915407996-3:1:1:2,
destinations=1, dispatched=0, delivered=0, pending=0, already
dispatched/paged count: 3 | org.apache.activemq.broker.region.Queue |
ActiveMQ BrokerService[localhost] Task-5
2015-02-02 14:27:18,340 | DEBUG | deltas_cmsapi toPageIn: 200, Inflight: 2,
pagedInMessages.size 3, enqueueCount: 0, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost]
Task-5
2015-02-02 14:27:18,340 | DEBUG | dispatch to browser:
QueueBrowserSubscription: consumer=ID:blah-53146-1422915407996-3:1:1:2,
destinations=1, dispatched=2, delivered=0, pending=0, already
dispatched/paged count: 3 | org.apache.activemq.broker.region.Queue |
ActiveMQ BrokerService[localhost] Task-5
2015-02-02 14:27:18,343 | DEBUG | deltas_cmsapi toPageIn: 200, Inflight: 1,
pagedInMessages.size 3, enqueueCount: 0, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost]
Task-6
2015-02-02 14:27:18,345 | DEBUG | deltas_cmsapi toPageIn: 200, Inflight: 0,
pagedInMessages.size 3, enqueueCount: 0, dequeueCount: 0 |
org.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost]
Task-6
2015-02-02 14:27:18,346 | DEBUG | remove:
ID:blah-53146-1422915407996-3:1:1:2, lastDeliveredSequenceId:454 |
org.apache.activemq.ActiveMQMessageConsumer | qtp1055629929-41
2015-02-02 14:27:18,347 | DEBUG | Unregistering MBean
org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=deltas_cmsapi,endpoint=Consumer,clientId=ID_blah-53146-1422915407996-2_1,consumerId=ID_blah-53146-1422915407996-3_1_1_2
| org.apache.activemq.broker.jmx.ManagementContext | ActiveMQ VMTransport:
vm://localhost#1-2
2015-02-02 14:27:18,347 | DEBUG | localhost removing consumer:
ID:blah-53146-1422915407996-3:1:1:2 for destination: queue://deltas_cmsapi
| org.apache.activemq.broker.region.AbstractRegion | ActiveMQ VMTransport:
vm://localhost#1-2
--
Jon Gorrono
PGP Key: 0x5434509D - http{
pgp.mit.edu:11371/pks/lookup?search=0x5434509D&op=index}
http{middleware.ucdavis.edu}
