diff options
Diffstat (limited to 'cpp/src/qpid/framing/AMQFrame.h')
-rw-r--r-- | cpp/src/qpid/framing/AMQFrame.h | 11 |
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; }; |