From b0a120b4edfdb49a08bd7c8c2479e7b1cadc5233 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 30 Oct 2006 19:27:54 +0000 Subject: Initial implementation for tx class. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469242 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/DirectExchange.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/broker/DirectExchange.cpp') diff --git a/cpp/src/qpid/broker/DirectExchange.cpp b/cpp/src/qpid/broker/DirectExchange.cpp index 63cfda8f51..46693f6f3c 100644 --- a/cpp/src/qpid/broker/DirectExchange.cpp +++ b/cpp/src/qpid/broker/DirectExchange.cpp @@ -51,12 +51,12 @@ void DirectExchange::unbind(Queue::shared_ptr queue, const string& routingKey, F lock.release(); } -void DirectExchange::route(Message::shared_ptr& msg, const string& routingKey, FieldTable* /*args*/){ +void DirectExchange::route(Deliverable& msg, const string& routingKey, FieldTable* /*args*/){ lock.acquire(); std::vector& queues(bindings[routingKey]); int count(0); for(std::vector::iterator i = queues.begin(); i != queues.end(); i++, count++){ - (*i)->deliver(msg); + msg.deliverTo(*i); } if(!count){ std::cout << "WARNING: DirectExchange " << getName() << " could not route message with key " << routingKey << std::endl; -- cgit v1.2.1