summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/framing/AMQFrame.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/framing/AMQFrame.h')
-rw-r--r--cpp/src/qpid/framing/AMQFrame.h11
1 files changed, 8 insertions, 3 deletions
diff --git a/cpp/src/qpid/framing/AMQFrame.h b/cpp/src/qpid/framing/AMQFrame.h
index 8c18475d29..a96b0483b7 100644
--- a/cpp/src/qpid/framing/AMQFrame.h
+++ b/cpp/src/qpid/framing/AMQFrame.h
@@ -37,14 +37,14 @@ namespace framing {
class AMQFrame : public AMQDataBlock
{
public:
- AMQFrame() : channel(0) {}
+ AMQFrame() : bof(true), eof(true), bos(true), eos(true), subchannel(0), channel(0) {}
/** Construct a frame with a copy of b */
- AMQFrame(ChannelId c, const AMQBody* b) : channel(c) {
+ AMQFrame(ChannelId c, const AMQBody* b) : bof(true), eof(true), bos(true), eos(true), subchannel(0), channel(c) {
setBody(*b);
}
- AMQFrame(ChannelId c, const AMQBody& b) : channel(c) {
+ AMQFrame(ChannelId c, const AMQBody& b) : bof(true), eof(true), bos(true), eos(true), subchannel(0), channel(c) {
setBody(b);
}
@@ -97,6 +97,11 @@ class AMQFrame : public AMQDataBlock
void decodeBody(Buffer& buffer, uint32_t size, uint8_t type);
+ bool bof;
+ bool eof;
+ bool bos;
+ bool eos;
+ uint8_t subchannel;
uint16_t channel;
Variant body;
};