Author: ritchiem
Date: 2009-02-13 10:13:27 -0500 (Fri, 13 Feb 2009)
New Revision: 3118
Modified:
store/branches/java/broker-queue-refactor/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
Log:
Update to the change in the MessageFactory, such that all messages created via recovery so
by id are created persistent
Modified:
store/branches/java/broker-queue-refactor/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
===================================================================
---
store/branches/java/broker-queue-refactor/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java 2009-02-13
11:41:24 UTC (rev 3117)
+++
store/branches/java/broker-queue-refactor/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java 2009-02-13
15:13:27 UTC (rev 3118)
@@ -1667,7 +1667,7 @@
else
{
- message = (PersistentAMQMessage)
_messageFactory.createMessage(messageId, this, true);
+ message = (PersistentAMQMessage)
_messageFactory.createMessage(messageId, this);
msgMap.put(messageId, message);
MessageMetaData mmd = getMessageMetaData(context, messageId);
Show replies by date