[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