summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2009-11-16 17:30:23 +0000
committerGordon Sim <gsim@apache.org>2009-11-16 17:30:23 +0000
commit771ac3e530a701120a933034f29659d16d5b4e85 (patch)
tree10216c075c1280ca13bfe8d946026ac26fbebc5b /cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
parent9c3dda9cf4bc359e68587767dd2ab072cf4a1298 (diff)
downloadqpid-python-771ac3e530a701120a933034f29659d16d5b4e85.tar.gz
QPID-664: Remove start()/stop() methods from api
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@880863 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/amqp0_10/SessionImpl.cpp')
-rw-r--r--cpp/src/qpid/client/amqp0_10/SessionImpl.cpp9
1 files changed, 7 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
index d0085dad75..4d40bd6c50 100644
--- a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
+++ b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
@@ -344,13 +344,18 @@ void SessionImpl::commitImpl()
void SessionImpl::rollbackImpl()
{
- for (Receivers::iterator i = receivers.begin(); i != receivers.end(); ++i) i->second.stop();
+ for (Receivers::iterator i = receivers.begin(); i != receivers.end(); ++i) {
+ getImplPtr<Receiver, ReceiverImpl>(i->second)->stop();
+ }
//ensure that stop has been processed and all previously sent
//messages are available for release:
session.sync();
incoming.releaseAll();
session.txRollback();
- for (Receivers::iterator i = receivers.begin(); i != receivers.end(); ++i) i->second.start();
+
+ for (Receivers::iterator i = receivers.begin(); i != receivers.end(); ++i) {
+ getImplPtr<Receiver, ReceiverImpl>(i->second)->start();
+ }
}
void SessionImpl::acknowledgeImpl()