diff --git a/src/confirmframe.h b/src/confirmframe.h index 02377f9..0337635 100644 --- a/src/confirmframe.h +++ b/src/confirmframe.h @@ -1,56 +1,56 @@ -/** - * Class describing an AMQP confirm frame - * - * @author Marcin Gibula - * @copyright 2017 Copernica BV - */ - -/** - * Set up namespace - */ -namespace AMQP { - -/** - * Class implementation - */ -class ConfirmFrame : public MethodFrame -{ -protected: - /** - * Constructor - * @param channel channel identifier - * @param size frame size - */ - ConfirmFrame(uint16_t channel, uint32_t size) : - MethodFrame(channel, size) - {} - - /** - * Constructor based on incoming frame - * @param frame - */ - ConfirmFrame(ReceivedFrame &frame) : - MethodFrame(frame) - {} - -public: - /** - * Destructor - */ - virtual ~ConfirmFrame() {} - - /** - * Class id - * @return uint16_t - */ - virtual uint16_t classID() const override - { - return 85; - } -}; - -/** - * end namespace - */ -} - +/** + * Class describing an AMQP confirm frame + * + * @author Marcin Gibula + * @copyright 2017 Copernica BV + */ + +/** + * Set up namespace + */ +namespace AMQP { + +/** + * Class implementation + */ +class ConfirmFrame : public MethodFrame +{ +protected: + /** + * Constructor + * @param channel channel identifier + * @param size frame size + */ + ConfirmFrame(uint16_t channel, uint32_t size) : + MethodFrame(channel, size) + {} + + /** + * Constructor based on incoming frame + * @param frame + */ + ConfirmFrame(ReceivedFrame &frame) : + MethodFrame(frame) + {} + +public: + /** + * Destructor + */ + virtual ~ConfirmFrame() {} + + /** + * Class id + * @return uint16_t + */ + virtual uint16_t classID() const override + { + return 85; + } +}; + +/** + * end namespace + */ +} + diff --git a/src/confirmselectframe.h b/src/confirmselectframe.h index 26ef3ba..809bfef 100644 --- a/src/confirmselectframe.h +++ b/src/confirmselectframe.h @@ -1,88 +1,88 @@ -/** - * Class describing an AMQP confirm select frame - * - * @author Marcin Gibula - * @copyright 2017 Copernica BV - */ - -/** - * Set up namespace - */ -namespace AMQP { - -/** - * Class implementation - */ -class ConfirmSelectFrame : public ConfirmFrame -{ -private: - - /** - * whether to wait for a response - * @var BooleanSet - */ - BooleanSet _noWait; - -protected: - /** - * Encode a frame on a string buffer - * - * @param buffer buffer to write frame to - */ - virtual void fill(OutBuffer& buffer) const override - { - // call base - ConfirmFrame::fill(buffer); - - // add boolean - _noWait.fill(buffer); - } - -public: - /** - * Decode a confirm select frame from a received frame - * - * @param frame received frame to decode - */ - ConfirmSelectFrame(ReceivedFrame& frame) : ConfirmFrame(frame), _noWait(frame) {} - - /** - * Construct a confirm select frame - * - * @param channel channel identifier - * @return newly created confirm select frame - */ - ConfirmSelectFrame(uint16_t channel, bool noWait = false) : - ConfirmFrame(channel, 1), //sizeof bool - _noWait(noWait) - {} - - /** - * Destructor - */ - virtual ~ConfirmSelectFrame() {} - - /** - * return the method id - * @return uint16_t - */ - virtual uint16_t methodID() const override - { - return 10; - } - - /** - * Return whether to wait for a response - * @return boolean - */ - bool noWait() const - { - return _noWait.get(0); - } -}; - -/** - * end namespace - */ -} - +/** + * Class describing an AMQP confirm select frame + * + * @author Marcin Gibula + * @copyright 2017 Copernica BV + */ + +/** + * Set up namespace + */ +namespace AMQP { + +/** + * Class implementation + */ +class ConfirmSelectFrame : public ConfirmFrame +{ +private: + + /** + * whether to wait for a response + * @var BooleanSet + */ + BooleanSet _noWait; + +protected: + /** + * Encode a frame on a string buffer + * + * @param buffer buffer to write frame to + */ + virtual void fill(OutBuffer& buffer) const override + { + // call base + ConfirmFrame::fill(buffer); + + // add boolean + _noWait.fill(buffer); + } + +public: + /** + * Decode a confirm select frame from a received frame + * + * @param frame received frame to decode + */ + ConfirmSelectFrame(ReceivedFrame& frame) : ConfirmFrame(frame), _noWait(frame) {} + + /** + * Construct a confirm select frame + * + * @param channel channel identifier + * @return newly created confirm select frame + */ + ConfirmSelectFrame(uint16_t channel, bool noWait = false) : + ConfirmFrame(channel, 1), //sizeof bool + _noWait(noWait) + {} + + /** + * Destructor + */ + virtual ~ConfirmSelectFrame() {} + + /** + * return the method id + * @return uint16_t + */ + virtual uint16_t methodID() const override + { + return 10; + } + + /** + * Return whether to wait for a response + * @return boolean + */ + bool noWait() const + { + return _noWait.get(0); + } +}; + +/** + * end namespace + */ +} + diff --git a/src/confirmselectokframe.h b/src/confirmselectokframe.h index c91c018..042f479 100644 --- a/src/confirmselectokframe.h +++ b/src/confirmselectokframe.h @@ -1,89 +1,89 @@ -/** - * Class describing an AMQP confirm select ok frame - * - * @author Marcin Gibula - * @copyright 2017 Copernica BV - */ - -/** - * Set up namespace - */ -namespace AMQP { - -/** - * Class implementation - */ -class ConfirmSelectOKFrame : public ConfirmFrame -{ -protected: - /** - * Encode a frame on a string buffer - * - * @param buffer buffer to write frame to - */ - virtual void fill(OutBuffer& buffer) const override - { - // call base - ConfirmFrame::fill(buffer); - } - -public: - /** - * Constructor for an incoming frame - * - * @param frame received frame to decode - */ - ConfirmSelectOKFrame(ReceivedFrame& frame) : - ConfirmFrame(frame) - {} - - /** - * Construct a confirm select ok frame - * - * @param channel channel identifier - * @return newly created confirm select ok frame - */ - ConfirmSelectOKFrame(uint16_t channel) : - ConfirmFrame(channel, 0) - {} - - /** - * Destructor - */ - virtual ~ConfirmSelectOKFrame() {} - - /** - * return the method id - * @return uint16_t - */ - virtual uint16_t methodID() const override - { - return 11; - } - - /** - * Process the frame - * @param connection The connection over which it was received - * @return bool Was it succesfully processed? - */ - virtual bool process(ConnectionImpl *connection) override - { - // we need the appropriate channel - auto channel = connection->channel(this->channel()); - - // channel does not exist - if(!channel) return false; - - // report that the channel is open - channel->reportSuccess(); - - // done - return true; - } -}; - -/** - * end namespace - */ -} - +/** + * Class describing an AMQP confirm select ok frame + * + * @author Marcin Gibula + * @copyright 2017 Copernica BV + */ + +/** + * Set up namespace + */ +namespace AMQP { + +/** + * Class implementation + */ +class ConfirmSelectOKFrame : public ConfirmFrame +{ +protected: + /** + * Encode a frame on a string buffer + * + * @param buffer buffer to write frame to + */ + virtual void fill(OutBuffer& buffer) const override + { + // call base + ConfirmFrame::fill(buffer); + } + +public: + /** + * Constructor for an incoming frame + * + * @param frame received frame to decode + */ + ConfirmSelectOKFrame(ReceivedFrame& frame) : + ConfirmFrame(frame) + {} + + /** + * Construct a confirm select ok frame + * + * @param channel channel identifier + * @return newly created confirm select ok frame + */ + ConfirmSelectOKFrame(uint16_t channel) : + ConfirmFrame(channel, 0) + {} + + /** + * Destructor + */ + virtual ~ConfirmSelectOKFrame() {} + + /** + * return the method id + * @return uint16_t + */ + virtual uint16_t methodID() const override + { + return 11; + } + + /** + * Process the frame + * @param connection The connection over which it was received + * @return bool Was it succesfully processed? + */ + virtual bool process(ConnectionImpl *connection) override + { + // we need the appropriate channel + auto channel = connection->channel(this->channel()); + + // channel does not exist + if(!channel) return false; + + // report that the channel is open + channel->reportSuccess(); + + // done + return true; + } +}; + +/** + * end namespace + */ +} +