diff options
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); |