diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/amqp/Outgoing.h')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Outgoing.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Outgoing.h b/qpid/cpp/src/qpid/broker/amqp/Outgoing.h index a63a8cc0a6..86d7d46111 100644 --- a/qpid/cpp/src/qpid/broker/amqp/Outgoing.h +++ b/qpid/cpp/src/qpid/broker/amqp/Outgoing.h @@ -88,7 +88,7 @@ class Outgoing : public ManagedOutgoingLink class OutgoingFromQueue : public Outgoing, public qpid::broker::Consumer, public boost::enable_shared_from_this<OutgoingFromQueue> { public: - OutgoingFromQueue(Broker&, const std::string& source, const std::string& target, boost::shared_ptr<Queue> q, pn_link_t* l, Session&, qpid::sys::OutputControl& o, bool exclusive); + OutgoingFromQueue(Broker&, const std::string& source, const std::string& target, boost::shared_ptr<Queue> q, pn_link_t* l, Session&, qpid::sys::OutputControl& o, bool exclusive, bool isControllingUser); void setSubjectFilter(const std::string&); void setSelectorFilter(const std::string&); void init(); @@ -124,6 +124,7 @@ class OutgoingFromQueue : public Outgoing, public qpid::broker::Consumer, public }; const bool exclusive; + const bool isControllingUser; boost::shared_ptr<Queue> queue; CircularArray<Record> deliveries; pn_link_t* link; |