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 | 8f189100ce13845fe48c137b096007c7a42640f5 (patch) | |
| tree | f0357c4cd585ad6e6416a2d845db3ad84417155c /cpp/src | |
| parent | 38000643066ef75bf0ab10e42989a25fa2ccbccd (diff) | |
| download | qpid-python-8f189100ce13845fe48c137b096007c7a42640f5.tar.gz | |
QPID-5416: esure message publisher is set
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1549993 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/broker/amqp/Incoming.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/amqp/Incoming.cpp b/cpp/src/qpid/broker/amqp/Incoming.cpp index f54328bc2e..347c3eb14d 100644 --- a/cpp/src/qpid/broker/amqp/Incoming.cpp +++ b/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); |