[rhmessaging-commits] rhmessaging commits: r3118 - store/branches/java/broker-queue-refactor/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Fri Feb 13 10:13:28 EST 2009
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);
More information about the rhmessaging-commits
mailing list