diff options
| author | Gordon Sim <gsim@apache.org> | 2013-12-10 22:52:39 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-12-10 22:52:39 +0000 |
| commit | d4568416aa38ec7f0317d8d05a2a304f08dc39a8 (patch) | |
| tree | df60e7a7608d1f5a7b94aa3c40d3c35af0daf24b /qpid/cpp/src | |
| parent | c52b4b966e4127aa2c965a4d29560b13cefcdc20 (diff) | |
| download | qpid-python-d4568416aa38ec7f0317d8d05a2a304f08dc39a8.tar.gz | |
QPID-5416: esure message publisher is set
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1549993 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Incoming.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
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); |