From 1a3413543de501ccafde8a39884d460dea764f9e Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Fri, 25 Jan 2013 21:32:42 +0000 Subject: QPID-4541 Added the ability to turn off replay at the time the session is created. The XASessionImpl will use this feature to turn off replay on the underlying JMS session. This prevents messages being replayed outside the boundaries of the XA transaction. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1438725 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java | 2 +- .../src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'qpid/java/client/src') diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java b/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java index 05bd121bbd..e01ec8578d 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java @@ -88,7 +88,7 @@ public class XASessionImpl extends AMQSession_0_10 implements XASession, XATopic */ public void createSession() { - _qpidDtxSession = getQpidConnection().createSession(0); + _qpidDtxSession = getQpidConnection().createSession(0,true); _qpidDtxSession.setSessionListener(this); _qpidDtxSession.dtxSelect(); } diff --git a/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java b/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java index 59181c3a13..d4e0ee60a6 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java @@ -597,7 +597,7 @@ public class AMQSession_0_10Test extends QpidTestCase connection.setSessionFactory(new SessionFactory() { - public Session newSession(Connection conn, Binary name, long expiry) + public Session newSession(Connection conn, Binary name, long expiry, boolean isNoReplay) { return new MockSession(conn, new SessionDelegate(), name, expiry, throwException); } -- cgit v1.2.1