diff options
Diffstat (limited to 'cpp/src/qpid/client/SessionImpl.cpp')
-rw-r--r-- | cpp/src/qpid/client/SessionImpl.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/client/SessionImpl.cpp b/cpp/src/qpid/client/SessionImpl.cpp index 3d73d92bd4..3e1ea8b724 100644 --- a/cpp/src/qpid/client/SessionImpl.cpp +++ b/cpp/src/qpid/client/SessionImpl.cpp @@ -427,13 +427,13 @@ void SessionImpl::handleIn(AMQFrame& frame) // network thread void SessionImpl::handleOut(AMQFrame& frame) // user thread { - connection->expand(frame.size(), true); + connection->expand(frame.encodedSize(), true); channel.handle(frame); } void SessionImpl::proxyOut(AMQFrame& frame) // network thread { - connection->expand(frame.size(), false); + connection->expand(frame.encodedSize(), false); channel.handle(frame); } @@ -523,7 +523,7 @@ void SessionImpl::commandPoint(const framing::SequenceNumber& id, uint64_t offse void SessionImpl::expected(const framing::SequenceSet& commands, const framing::Array& fragments) { - if (!commands.empty() || fragments.size()) { + if (!commands.empty() || fragments.encodedSize()) { throw NotImplementedException("Session resumption not yet supported"); } } |