summaryrefslogtreecommitdiff
path: root/cpp/lib/common/framing/AMQResponseBody.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/common/framing/AMQResponseBody.cpp')
-rw-r--r--cpp/lib/common/framing/AMQResponseBody.cpp7
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