You got some, not all, of what JMX would have told you. But it's enough.
DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401,
subscriptions=2, memory=0%, size=2, pending=0 toPageIn: 1, Inflight: 1,
pagedInMessages.size 1, pagedInPendingDispatch.size 0, enqueueCount: 2,
dequeueCount: 0, memUsage:3155
Why is subscriptions=2? What's your second consumer, and why is it there
when it shouldn't be?
With a JMX viewer, you'd have seen the second subscription, seen that each
consumer gets one of the messages, and not had to ask your follow-up
question. So, what does "not having much luck with the JMX viewer" mean,
and how can we help you learn whatever you need to so you can use one
successfully in the future?
Tim
On Mar 10, 2016 12:58 PM, "swift99" <djohn...@maxistechnology.com> wrote:
> I'm not having much luck with the JMX viewer, but I turned on debug logging
> to get (I think) the same information.
>
> It is very clear that there was two enqueues and one dequeue, with the
> dequeue of the "end-of-data marker" happening before the dequeue of the
> intended data.
>
> Log entries follow:
>
> INFO com.myapp.SourceSelectionReaderImpl - 1 rows were selected as roots
> in
> 602 milliseconds.
> DEBUG org.apache.activemq.broker.region.Queue - localhost Message
> ID:zip-54580-1457638742697-4:2:2:1:1 sent to queue://Stuff via SQL.401
> DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401,
> subscriptions=2, memory=0%, size=1, pending=0 toPageIn: 1, Inflight: 0,
> pagedInMessages.size 0, pagedInPendingDispatch.size 0, enqueueCount: 1,
> dequeueCount: 0, memUsage:2214
> INFO com.myapp.SelectedDataJmsWriter - Committed 1 thing to redo log and
> JMS queue
>
> *** Emphasis added - Note that the end of stream marker is posted second
> ***
> INFO com.myapp.SourceSelectionReaderImpl - Returning empty thing and
> end-of-stream placeholder.
> DEBUG org.apache.activemq.broker.region.Queue - localhost Message
> ID:zip-54580-1457638742697-4:2:2:1:2 sent to queue://Stuff via SQL.401
> DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401,
> subscriptions=2, memory=0%, size=2, pending=0 toPageIn: 1, Inflight: 1,
> pagedInMessages.size 1, pagedInPendingDispatch.size 0, enqueueCount: 2,
> dequeueCount: 0, memUsage:3155
> INFO com.myapp.SelectedDataJmsWriter - Committed 1 thing to redo log and
> JMS queue
>
> *** Emphasis added - note that the end of stream marker is retrieved first,
> the first one is still marked as inflight ***
> INFO com.myapp.SelectedDataJmsReader - executed read, found end-of-stream
> marker, returning null
> DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401,
> subscriptions=2, memory=0%, size=1, pending=0 toPageIn: 0, Inflight: 1,
> pagedInMessages.size 1, pagedInPendingDispatch.size 0, enqueueCount: 2,
> dequeueCount: 1, memUsage:1107
>
>
> DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401,
> subscriptions=2, memory=0%, size=1, pending=0 toPageIn: 0, Inflight: 1,
> pagedInMessages.size 1, pagedInPendingDispatch.size 0, enqueueCount: 2,
> dequeueCount: 1, memUsage:1107
> DEBUG org.apache.activemq.broker.region.AbstractRegion - localhost removing
> consumer: ID:zip-54580-1457638742697-4:1:2:1 for destination: queue://Stuff
> via SQL.401
> DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401
> remove sub: QueueSubscription: consumer=ID:zip-54580-1457638742697-4:1:2:1,
> destinations=1, dispatched=0, delivered=0, pending=0, lastDeliveredSeqId:
> 9,
> dequeues: 1, dispatched: 2, inflight: 1, groups: 0
> DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401,
> subscriptions=1, memory=0%, size=1, pending=0 toPageIn: 0, Inflight: 1,
> pagedInMessages.size 1, pagedInPendingDispatch.size 0, enqueueCount: 2,
> dequeueCount: 1, memUsage:1107
> INFO org.springframework.batch.core.launch.support.SimpleJobLauncher -
> Job:
> [FlowJob: [name=archive-purge]] completed with the following parameters:
> [{jobName=Stuff via SQL}] and the following status: [COMPLETED]
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-JMS-losing-messages-what-am-I-missing-tp4709127p4709178.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
