summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/messaging/Session.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/messaging/Session.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/messaging/Session.cpp')
-rw-r--r--cpp/src/qpid/messaging/Session.cpp9
1 files changed, 2 insertions, 7 deletions
diff --git a/cpp/src/qpid/messaging/Session.cpp b/cpp/src/qpid/messaging/Session.cpp
index cc0b528777..eb5e3766b8 100644
--- a/cpp/src/qpid/messaging/Session.cpp
+++ b/cpp/src/qpid/messaging/Session.cpp
@@ -61,14 +61,9 @@ Receiver Session::createReceiver(const std::string& address)
return impl->createReceiver(Address(address));
}
-void Session::sync()
+void Session::sync(bool block)
{
- impl->sync();
-}
-
-void Session::flush()
-{
- impl->flush();
+ impl->sync(block);
}
bool Session::nextReceiver(Receiver& receiver, Duration timeout)