You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2009/07/01 18:11:30 UTC
svn commit: r790246 -
/activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/apollo/broker/BrokerMessageDelivery.java
Author: chirino
Date: Wed Jul 1 16:11:29 2009
New Revision: 790246
URL: http://svn.apache.org/viewvc?rev=790246&view=rev
Log:
tid should be initialized with as that's the no TX identifier
Modified:
activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/apollo/broker/BrokerMessageDelivery.java
Modified: activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/apollo/broker/BrokerMessageDelivery.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/apollo/broker/BrokerMessageDelivery.java?rev=790246&r1=790245&r2=790246&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/apollo/broker/BrokerMessageDelivery.java (original)
+++ activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/apollo/broker/BrokerMessageDelivery.java Wed Jul 1 16:11:29 2009
@@ -48,8 +48,7 @@
boolean fromStore = false;
boolean enableFlushDelay = true;
private int limiterSize = -1;
-
- private long tid;
+ private long tid=-1;
public void setFromDatabase(BrokerDatabase database, MessageRecord mRecord) {
fromStore = true;