diff options
Diffstat (limited to 'cpp/lib/common/framing/AMQResponseBody.cpp')
-rw-r--r-- | cpp/lib/common/framing/AMQResponseBody.cpp | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/lib/common/framing/AMQResponseBody.cpp b/cpp/lib/common/framing/AMQResponseBody.cpp index c64b1325d6..dffbb62aca 100644 --- a/cpp/lib/common/framing/AMQResponseBody.cpp +++ b/cpp/lib/common/framing/AMQResponseBody.cpp @@ -16,6 +16,7 @@ * */ +#include "AMQFrame.h" #include "AMQResponseBody.h" #include "AMQP_MethodVersionMap.h" @@ -61,5 +62,11 @@ void AMQResponseBody::printPrefix(std::ostream& out) const { << ",batch=" << data.batchOffset << "): "; } +void AMQResponseBody::send(const MethodContext& context) { + setRequestId(context.requestId); + assert(context.out); + context.out->send( + new AMQFrame(version, context.channelId, this)); +} }} // namespace qpid::framing |