Author: rajdavies
Date: Thu Feb 2 00:56:23 2006
New Revision: 374309
URL: http://svn.apache.org/viewcvs?rev=374309&view=rev
Log:
return IntegerResponse from prepareTransaction()
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/AbstractConnection.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/AbstractConnection.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/AbstractConnection.java?rev=374309&r1=374308&r2=374309&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/AbstractConnection.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/AbstractConnection.java
Thu Feb 2 00:56:23 2006
@@ -37,6 +37,7 @@
import org.apache.activemq.command.DestinationInfo;
import org.apache.activemq.command.ExceptionResponse;
import org.apache.activemq.command.FlushCommand;
+import org.apache.activemq.command.IntegerResponse;
import org.apache.activemq.command.KeepAliveInfo;
import org.apache.activemq.command.Message;
import org.apache.activemq.command.MessageAck;
@@ -278,8 +279,9 @@
if( cs!=null ) {
context = cs.getContext();
}
- broker.prepareTransaction(context, info.getTransactionId());
- return null;
+ int result = broker.prepareTransaction(context,
info.getTransactionId());
+ IntegerResponse response = new IntegerResponse(result);
+ return response;
}
public Response processCommitTransactionOnePhase(TransactionInfo info)
throws Throwable {
