From d4568416aa38ec7f0317d8d05a2a304f08dc39a8 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Tue, 10 Dec 2013 22:52:39 +0000
Subject: QPID-5416: esure message publisher is set

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1549993 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/cpp/src/qpid/broker/amqp/Incoming.cpp | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'qpid/cpp/src')

diff --git a/qpid/cpp/src/qpid/broker/amqp/Incoming.cpp b/qpid/cpp/src/qpid/broker/amqp/Incoming.cpp
index f54328bc2e..347c3eb14d 100644
--- a/qpid/cpp/src/qpid/broker/amqp/Incoming.cpp
+++ b/qpid/cpp/src/qpid/broker/amqp/Incoming.cpp
@@ -20,6 +20,7 @@
  */
 #include "Incoming.h"
 #include "Exception.h"
+#include "ManagedConnection.h"
 #include "Message.h"
 #include "Session.h"
 #include "qpid/amqp/descriptors.h"
@@ -116,6 +117,7 @@ void DecodingIncoming::readable(pn_delivery_t* delivery)
     pn_link_advance(link);
 
     qpid::broker::Message message(received, received);
+    message.setPublisher(session->getParent());
     userid.verify(message.getUserId());
     message.computeExpiration(expiryPolicy);
     handle(message);
-- 
cgit v1.2.1