diff options
| author | Gordon Sim <gsim@apache.org> | 2014-12-17 14:29:44 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2014-12-17 14:29:44 +0000 |
| commit | faec291315dc851eefa59b63f3c7107888b75f98 (patch) | |
| tree | 4715e5a7718ef91759230c49e4d218707a9f2397 /qpid/cpp/src/qpid/broker/amqp/Outgoing.h | |
| parent | 9f634ba1b0f2ee6ea2f2e0c3a7a3d892d3eeda7c (diff) | |
| download | qpid-python-faec291315dc851eefa59b63f3c7107888b75f98.tar.gz | |
QPID-6274: Delete subscription queue immediately on link close
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646260 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/amqp/Outgoing.h')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Outgoing.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Outgoing.h b/qpid/cpp/src/qpid/broker/amqp/Outgoing.h index 27d8205fc8..d3825d0894 100644 --- a/qpid/cpp/src/qpid/broker/amqp/Outgoing.h +++ b/qpid/cpp/src/qpid/broker/amqp/Outgoing.h @@ -70,7 +70,7 @@ class Outgoing : public ManagedOutgoingLink /** * Signals that this link has been detached */ - virtual void detached() = 0; + virtual void detached(bool closed) = 0; /** * Called when a delivery is writable */ @@ -98,7 +98,7 @@ class OutgoingFromQueue : public Outgoing, public qpid::broker::Consumer, public void write(const char* data, size_t size); void handle(pn_delivery_t* delivery); bool canDeliver(); - void detached(); + void detached(bool closed); //Consumer interface: bool deliver(const QueueCursor& cursor, const qpid::broker::Message& msg); |