On Mon, Mar 4, 2013 at 12:54 PM, Richard Peter <[email protected]> wrote: > Ok, this wasn't an issue with the C++ broker, if a queue was marked durable > any message was persisted. Thanks for the clarification.
This is not correct. You need to mark the the message as persistent in order for it to be written to disk. Rajith > > > 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] > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
