summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/SessionBase_0_10.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-04-07 19:41:44 +0000
committerGordon Sim <gsim@apache.org>2010-04-07 19:41:44 +0000
commit00e14b01033ae8c33399bc6ebfd28930498b2533 (patch)
tree3615da0715bfe4f09bb930f108611f47d3ae794c /cpp/src/qpid/client/SessionBase_0_10.cpp
parent736179f004fbc65bb82f0ceade570375197e29e7 (diff)
downloadqpid-python-00e14b01033ae8c33399bc6ebfd28930498b2533.tar.gz
QPID-664: removed flush, added option to make sync non-blocking if so desired
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@931651 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SessionBase_0_10.cpp')
-rw-r--r--cpp/src/qpid/client/SessionBase_0_10.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SessionBase_0_10.cpp b/cpp/src/qpid/client/SessionBase_0_10.cpp
index e114b7aacc..6aa13bb579 100644
--- a/cpp/src/qpid/client/SessionBase_0_10.cpp
+++ b/cpp/src/qpid/client/SessionBase_0_10.cpp
@@ -65,6 +65,13 @@ void SessionBase_0_10::sendCompletion()
impl->sendCompletion();
}
+void SessionBase_0_10::sendSyncRequest()
+{
+ ExecutionSyncBody b;
+ b.setSync(true);
+ impl->send(b);
+}
+
uint16_t SessionBase_0_10::getChannel() const { return impl->getChannel(); }
void SessionBase_0_10::suspend() { impl->suspend(); }