Re: 0.18 Java broker not persisting message to derby store

Mon, 04 Mar 2013 09:55:27 -0800

Ok, this wasn't an issue with the C++ broker, if a queue was marked durable any message was persisted. Thanks for the clarification. 

On 03/04/2013 10:07 AM, Robbie Gemmell wrote:

Hi Richard,

The queue statistics suggest that you are not sending persistent messages:
"persistentEnqueuedMessages" : 0,
"totalEnqueuedMessages" : 161134,

Non-persistent messages are only ever stored in memory on the broker, and
it will only recover persistent messages which are sent to durable queues.

Robbie


On 4 March 2013 15:27, Richard Peter<[email protected]>  wrote:


I noticed that 0.18 Java Broker does not appear to be persisting message
to the derby store.  Running tests to verify memory thresholds in a
disaster recovery situation.  Had 100k+ messages on a durable queue with no
consumers.  When I bounced QPID, the memory usage was almost none and
noticed the log wasn't recovering any messages:

QPID2013-03-04 09:19:03,789 INFO  [main] (Log4jMessageLogger.java:73) -
[Broker] [vh(/edex)/ms(**DerbyMessageStore)] TXN-1004 : Recovery Start
2013-03-04 09:19:03,808 INFO  [main] (Log4jMessageLogger.java:73) -
[Broker] [vh(/edex)/ms(**DerbyMessageStore)] TXN-1005 : Recovered 0
messages for queue external.dropbox
2013-03-04 09:19:03,809 INFO  [main] (Log4jMessageLogger.java:73) -
[Broker] [vh(/edex)/ms(**DerbyMessageStore)] TXN-1006 : Recovery Complete
: external.dropbox
2013-03-04 09:19:03,817 INFO  [main] (Log4jMessageLogger.java:73) -
[Broker] [vh(/edex)/ms(**DerbyMessageStore)] TXN-1006 : Recovery Complete


Dug a little more and none of my durable queues are persisting.  Anything
I'm missing?  I do have the store configured in my virtualhosts.xml:

<store>
<class>org.apache.qpid.server.**store.derby.DerbyMessageStore<**/class>
<environment-path>${QPID_WORK}**/messageStore</environment-**path>
</store>

Here is a sample from the rest interface:

{
   "id" : "505024de-642d-3572-a80c-**750a1b9819e9",
   "name" : "external.dropbox",
   "state" : "ACTIVE",
   "durable" : true,
   "lifetimePolicy" : "PERMANENT",
   "type" : "standard",
   "exclusive" : false,
   "maximumDeliveryAttempts" : 0,
   "queueFlowControlSizeBytes" : 0,
   "queueFlowResumeSizeBytes" : 0,
   "queueFlowStopped" : false,
   "alertThresholdMessageAge" : 60000,
   "alertThresholdMessageSize" : 2117632,
   "**alertThresholdQueueDepthBytes" : 5294080,
   "**alertThresholdQueueDepthMessag**es" : 10000,
   "alertRepeatGap" : 30000,
   "statistics" : {
     "unacknowledgedBytes" : 0,
     "bindingCount" : 2,
     "queueDepthBytes" : 12697432,
     "queueDepthMessages" : 161134,
     "totalEnqueuedBytes" : 12697432,
     "persistentDequeuedBytes" : 0,
     "consumerCount" : 0,
     "unacknowledgedMessages" : 0,
     "consumerCountWithCredit" : 0,
     "totalDequeuedBytes" : 0,
     "totalDequeuedMessages" : 0,
     "persistentEnqueuedMessages" : 0,
     "totalEnqueuedMessages" : 161134,
     "persistentEnqueuedBytes" : 0,
     "persistentDequeuedMessages" : 0
   },
   "bindings" : [ {
     "id" : "d24e4587-ee99-3086-bc34-**056be3226f09",
     "name" : "external.dropbox",
     "durable" : true,
     "lifetimePolicy" : "PERMANENT",
     "exchange" : "amq.direct",
     "queue" : "external.dropbox",
     "arguments" : {
     }
   }, {
     "id" : "ac57bb00-a0aa-3c4e-a6d9-**276d3d520f39",
     "name" : "external.dropbox",
     "durable" : true,
     "lifetimePolicy" : "PERMANENT",
     "exchange" : "<<default>>",
     "queue" : "external.dropbox",
     "arguments" : {
     }
   } ]
}

Thanks,
Richard

Thanks,
Richard

------------------------------**------------------------------**---------
To unsubscribe, e-mail: 
[email protected].**org<[email protected]>
For additional commands, e-mail: [email protected]




---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to