From f0f17cdf1861d94e173e8555fa4aa5d4fe4b23a5 Mon Sep 17 00:00:00 2001 From: Raoul Wols Date: Wed, 28 Jul 2021 12:14:50 +0200 Subject: [PATCH] Remove unused ConsumedMessage class --- src/channelimpl.cpp | 1 - src/consumedmessage.h | 91 ------------------------------------------- src/receivedframe.cpp | 1 - 3 files changed, 93 deletions(-) delete mode 100644 src/consumedmessage.h diff --git a/src/channelimpl.cpp b/src/channelimpl.cpp index 5b185c7..56b2d1a 100644 --- a/src/channelimpl.cpp +++ b/src/channelimpl.cpp @@ -8,7 +8,6 @@ #include "includes.h" #include "basicgetokframe.h" #include "basicreturnframe.h" -#include "consumedmessage.h" #include "returnedmessage.h" #include "channelopenframe.h" #include "channelflowframe.h" diff --git a/src/consumedmessage.h b/src/consumedmessage.h deleted file mode 100644 index 21f4a6c..0000000 --- a/src/consumedmessage.h +++ /dev/null @@ -1,91 +0,0 @@ -/** - * Base class for a message implementation - * - * @copyright 2014 - 2018 Copernica BV - */ - -/** - * Dependencies - */ -#include "basicdeliverframe.h" - -/** - * Set up namespace - */ -namespace AMQP { - -/** - * Class definition - */ -class ConsumedMessage : public Message -{ -private: - /** - * The consumer tag - * @var string - */ - std::string _consumerTag; - - /** - * The delivery tag - * @var uint64_t - */ - uint64_t _deliveryTag; - - /** - * Is this a redelivered message? - * @var bool - */ - bool _redelivered; - - -public: - /** - * Constructor - * @param frame - */ - ConsumedMessage(const BasicDeliverFrame &frame) : - Message(frame.exchange(), frame.routingKey()), - _consumerTag(frame.consumerTag()), _deliveryTag(frame.deliveryTag()), _redelivered(frame.redelivered()) - {} - - /** - * Constructor - * @param frame - */ - ConsumedMessage(const BasicGetOKFrame &frame) : - Message(frame.exchange(), frame.routingKey()), - _deliveryTag(frame.deliveryTag()), _redelivered(frame.redelivered()) - {} - - - /** - * Destructor - */ - virtual ~ConsumedMessage() {} - - /** - * Retrieve the consumer tag - * @return std::string - */ - const std::string &consumer() const - { - return _consumerTag; - } - - /** - * Report to the handler - * @param callback - */ - void report(const MessageCallback &callback) - { - // send ourselves to the consumer - if (callback) callback(*this, _deliveryTag, _redelivered); - } -}; - -/** - * End of namespace - */ -} - diff --git a/src/receivedframe.cpp b/src/receivedframe.cpp index ce55d6d..742274a 100644 --- a/src/receivedframe.cpp +++ b/src/receivedframe.cpp @@ -67,7 +67,6 @@ #include "transactioncommitokframe.h" #include "transactionrollbackframe.h" #include "transactionrollbackokframe.h" -#include "consumedmessage.h" #include "bodyframe.h" #include "basicheaderframe.h"