From 08d70d83487d6c39cdef50f9c90e001787849286 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 23 Nov 2009 12:50:58 +0000 Subject: QPID-664: Allow session to be specified as transactional; add basic test of transaction implementation. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@883325 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/amqp0_10/SessionImpl.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'cpp/src/qpid/client/amqp0_10/SessionImpl.cpp') diff --git a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp index 0c09f26039..bb47288e88 100644 --- a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp +++ b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp @@ -50,7 +50,7 @@ namespace qpid { namespace client { namespace amqp0_10 { -SessionImpl::SessionImpl(ConnectionImpl& c) : connection(c) {} +SessionImpl::SessionImpl(ConnectionImpl& c, bool t) : connection(c), transactional(t) {} void SessionImpl::sync() @@ -134,6 +134,7 @@ void SessionImpl::setSession(qpid::client::Session s) qpid::sys::Mutex::ScopedLock l(lock); session = s; incoming.setSession(session); + if (transactional) session.txSelect(); for (Receivers::iterator i = receivers.begin(); i != receivers.end(); ++i) { getImplPtr(i->second)->init(session, resolver); } -- cgit v1.2.1