diff options
Diffstat (limited to 'cpp/src/qpid/amqp_0_10/SessionHandler.cpp')
| -rw-r--r-- | cpp/src/qpid/amqp_0_10/SessionHandler.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/cpp/src/qpid/amqp_0_10/SessionHandler.cpp b/cpp/src/qpid/amqp_0_10/SessionHandler.cpp index 0e57e4b3f1..2f6b59e901 100644 --- a/cpp/src/qpid/amqp_0_10/SessionHandler.cpp +++ b/cpp/src/qpid/amqp_0_10/SessionHandler.cpp @@ -299,6 +299,12 @@ void SessionHandler::sendCommandPoint(const SessionPoint& point) { } } +void SessionHandler::markReadyToSend() { + if (!sendReady) { + sendReady = true; + } +} + void SessionHandler::sendTimeout(uint32_t t) { checkAttached(); peer.requestTimeout(t); |