summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/messaging
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/messaging')
-rw-r--r--cpp/src/qpid/messaging/Session.cpp9
-rw-r--r--cpp/src/qpid/messaging/SessionImpl.h3
2 files changed, 3 insertions, 9 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)
diff --git a/cpp/src/qpid/messaging/SessionImpl.h b/cpp/src/qpid/messaging/SessionImpl.h
index 7f76f8556f..7acead5b04 100644
--- a/cpp/src/qpid/messaging/SessionImpl.h
+++ b/cpp/src/qpid/messaging/SessionImpl.h
@@ -44,8 +44,7 @@ class SessionImpl : public virtual qpid::RefCounted
virtual void reject(Message&) = 0;
virtual void release(Message&) = 0;
virtual void close() = 0;
- virtual void sync() = 0;
- virtual void flush() = 0;
+ virtual void sync(bool block) = 0;
virtual Sender createSender(const Address& address) = 0;
virtual Receiver createReceiver(const Address& address) = 0;
virtual bool nextReceiver(Receiver& receiver, Duration timeout) = 0;