diff options
Diffstat (limited to 'cpp/lib/broker/BrokerChannel.cpp')
| -rw-r--r-- | cpp/lib/broker/BrokerChannel.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/lib/broker/BrokerChannel.cpp b/cpp/lib/broker/BrokerChannel.cpp index ba1ccb7031..84ac747846 100644 --- a/cpp/lib/broker/BrokerChannel.cpp +++ b/cpp/lib/broker/BrokerChannel.cpp @@ -188,7 +188,9 @@ void Channel::ConsumerImpl::requestDispatch(){ if(blocked) queue->dispatch(); } -void Channel::handleInlineTransfer(Message::shared_ptr& msg, Exchange::shared_ptr& exch){ +void Channel::handleInlineTransfer( + Message::shared_ptr msg, Exchange::shared_ptr& exch) +{ if(transactional){ TxPublish* deliverable = new TxPublish(msg); exch->route(*deliverable, msg->getRoutingKey(), &(msg->getApplicationHeaders())); |