diff options
| author | Gordon Sim <gsim@apache.org> | 2013-03-18 18:01:45 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-03-18 18:01:45 +0000 |
| commit | 248116abe95421844fed3dc086895230e3f3fb74 (patch) | |
| tree | e868f657a5333913c1acd2311978cf65623ad453 /qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp | |
| parent | 8330679e7eaa87c814f3be37168c52d5b0f00396 (diff) | |
| download | qpid-python-248116abe95421844fed3dc086895230e3f3fb74.tar.gz | |
QPID-4586: some management related tweaks and fixes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1457898 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp b/qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp index e531e8cd20..7e98195a60 100644 --- a/qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp +++ b/qpid/cpp/src/qpid/broker/amqp/Outgoing.cpp @@ -33,15 +33,16 @@ namespace qpid { namespace broker { namespace amqp { -Outgoing::Outgoing(Broker& broker, Session& parent, const std::string& source, const std::string& name) : ManagedOutgoingLink(broker, parent, source, name), session(parent) {} +Outgoing::Outgoing(Broker& broker, Session& parent, const std::string& source, const std::string& target, const std::string& name) + : ManagedOutgoingLink(broker, parent, source, target, name), session(parent) {} void Outgoing::wakeup() { session.wakeup(); } -OutgoingFromQueue::OutgoingFromQueue(Broker& broker, const std::string& source, boost::shared_ptr<Queue> q, pn_link_t* l, Session& session, qpid::sys::OutputControl& o, bool topic) - : Outgoing(broker, session, source, pn_link_name(l)), +OutgoingFromQueue::OutgoingFromQueue(Broker& broker, const std::string& source, const std::string& target, boost::shared_ptr<Queue> q, pn_link_t* l, Session& session, qpid::sys::OutputControl& o, bool topic) + : Outgoing(broker, session, source, target, pn_link_name(l)), Consumer(pn_link_name(l), /*FIXME*/CONSUMER), exclusive(topic), queue(q), deliveries(5000), link(l), out(o), |