summaryrefslogtreecommitdiff
path: root/qpid/java/cluster
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2007-05-02 16:49:03 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2007-05-02 16:49:03 +0000
commit5338bcbb94ad3227b4689eacaec142945218eb1a (patch)
tree7892acb196079cb9aec1ece7591c83410ddd6a86 /qpid/java/cluster
parent3f3a7f6af8d3ceb4b48fdea7605a57b5f7bff2ee (diff)
downloadqpid-python-5338bcbb94ad3227b4689eacaec142945218eb1a.tar.gz
I am commiting the patch supplied by Arnaud Simon. This patch contains support for dtx.
Currently there is one test case failing. I will try to fix it, if not Arnuad will provide a patch soon git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@534541 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/cluster')
-rw-r--r--qpid/java/cluster/src/main/java/org/apache/qpid/server/cluster/ClusteredProtocolSession.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/java/cluster/src/main/java/org/apache/qpid/server/cluster/ClusteredProtocolSession.java b/qpid/java/cluster/src/main/java/org/apache/qpid/server/cluster/ClusteredProtocolSession.java
index eea660c4f0..2406bd8f3f 100644
--- a/qpid/java/cluster/src/main/java/org/apache/qpid/server/cluster/ClusteredProtocolSession.java
+++ b/qpid/java/cluster/src/main/java/org/apache/qpid/server/cluster/ClusteredProtocolSession.java
@@ -108,6 +108,7 @@ public class ClusteredProtocolSession extends AMQMinaProtocolSession
throws AMQException
{
super(ClusteredProtocolSession.this,channelId,
+ virtualHost.getTransactionManager(),
virtualHost.getMessageStore(),
virtualHost.getExchangeRegistry());
}