diff options
| author | Gordon Sim <gsim@apache.org> | 2012-11-15 14:42:22 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2012-11-15 14:42:22 +0000 |
| commit | abe66b3f8e18fc8b6f016b922db24100ff834734 (patch) | |
| tree | 2a10278bfdf15c18214d1642e1dd24eebd2a0a4f /cpp/src/qpid/messaging/amqp/SenderContext.h | |
| parent | 2bce3b0dd247227bc5ff1dd3f17f6903c66e9cce (diff) | |
| download | qpid-python-abe66b3f8e18fc8b6f016b922db24100ff834734.tar.gz | |
QPID-4368: Add support for subject, translated to a filter (i.e. at present a binding key) by receivers and used as default value for senders
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1409813 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/messaging/amqp/SenderContext.h')
| -rw-r--r-- | cpp/src/qpid/messaging/amqp/SenderContext.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/cpp/src/qpid/messaging/amqp/SenderContext.h b/cpp/src/qpid/messaging/amqp/SenderContext.h index 82c5e6dab9..bc73d199e7 100644 --- a/cpp/src/qpid/messaging/amqp/SenderContext.h +++ b/cpp/src/qpid/messaging/amqp/SenderContext.h @@ -25,6 +25,7 @@ #include <string> #include <vector> #include "qpid/sys/IntegerTypes.h" +#include "qpid/messaging/Address.h" #include "qpid/messaging/amqp/EncodedMessage.h" struct pn_delivery_t; @@ -48,7 +49,7 @@ class SenderContext { public: Delivery(int32_t id); - void encode(const qpid::messaging::MessageImpl& message); + void encode(const qpid::messaging::MessageImpl& message, const qpid::messaging::Address&); void send(pn_link_t*); bool accepted(); private: @@ -57,7 +58,7 @@ class SenderContext EncodedMessage encoded; }; - SenderContext(pn_session_t* session, const std::string& name, const std::string& target); + SenderContext(pn_session_t* session, const std::string& name, const qpid::messaging::Address& target); ~SenderContext(); void close(); void setCapacity(uint32_t); @@ -71,7 +72,7 @@ class SenderContext typedef std::deque<Delivery> Deliveries; const std::string name; - const std::string target; + const qpid::messaging::Address address; pn_link_t* sender; int32_t nextId; Deliveries deliveries; |