Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Date: Thu, 10 Mar 2016 11:30:29 -0800 (PST)
From: swift99 <djohnson@maxistechnology.com>
To: users@activemq.apache.org
Message-ID: <1457638229483-4709178.post@n4.nabble.com>
In-Reply-To: 
 <CAPVVMa-tH0sYzYi-_SoVQz_xhX9u18X-gWMJ5Gf19vtM+PwqRQ@mail.gmail.com>
References: <1457554287960-4709127.post@n4.nabble.com>
 <CAPVVMa-tH0sYzYi-_SoVQz_xhX9u18X-gWMJ5Gf19vtM+PwqRQ@mail.gmail.com>
Subject: =?UTF-8?Q?Re:_ActiveMQ_/_JMS_=E2=80=9Closing=E2=80=9D_?=
 =?UTF-8?Q?messages_-_what_am_I_missing=3F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

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.