diff options
author | Gordon Sim <gsim@apache.org> | 2010-04-07 19:41:44 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2010-04-07 19:41:44 +0000 |
commit | 00e14b01033ae8c33399bc6ebfd28930498b2533 (patch) | |
tree | 3615da0715bfe4f09bb930f108611f47d3ae794c /cpp/src/qpid/messaging/Session.cpp | |
parent | 736179f004fbc65bb82f0ceade570375197e29e7 (diff) | |
download | qpid-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.cpp | 9 |
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) |