diff options
Diffstat (limited to 'cpp/src/qpid/client/SessionBase.cpp')
| -rw-r--r-- | cpp/src/qpid/client/SessionBase.cpp | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SessionBase.cpp b/cpp/src/qpid/client/SessionBase.cpp index 06266ded91..9b6123cbc4 100644 --- a/cpp/src/qpid/client/SessionBase.cpp +++ b/cpp/src/qpid/client/SessionBase.cpp @@ -34,4 +34,11 @@ bool SessionBase::isSynchronous() const { return impl->isSync(); } Execution& SessionBase::getExecution() { return impl->getExecution(); } Uuid SessionBase::getId() const { return impl->getId(); } framing::FrameSet::shared_ptr SessionBase::get() { return impl->get(); } + +void SessionBase::sync() { + Execution& ex = getExecution(); + ex.syncWait(ex.lastSent()); + impl->assertOpen(); +} + }} // namespace qpid::client |