diff options
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Message.cpp | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp index 53cfe4ee43..b5292ef043 100644 --- a/cpp/src/qpid/broker/Message.cpp +++ b/cpp/src/qpid/broker/Message.cpp @@ -20,12 +20,11 @@ #include "qpid/broker/ExchangeRegistry.h" #include <iostream> -using namespace std::tr1;//for *_pointer_cast methods +using namespace boost; using namespace qpid::broker; using namespace qpid::framing; using namespace qpid::concurrent; - Message::Message(const ConnectionToken* const _publisher, const string& _exchange, const string& _routingKey, bool _mandatory, bool _immediate) : publisher(_publisher), @@ -34,12 +33,9 @@ Message::Message(const ConnectionToken* const _publisher, mandatory(_mandatory), immediate(_immediate), redelivered(false), - size(0){ + size(0) {} -} - -Message::~Message(){ -} +Message::~Message(){} void Message::setHeader(AMQHeaderBody::shared_ptr _header){ this->header = _header; @@ -61,7 +57,6 @@ void Message::redeliver(){ void Message::deliver(OutputHandler* out, int channel, const string& consumerTag, u_int64_t deliveryTag, u_int32_t framesize){ - out->send(new AMQFrame(channel, new BasicDeliverBody(consumerTag, deliveryTag, redelivered, exchange, routingKey))); sendContent(out, channel, framesize); } |
