From 5d1002299239fd4dd0c065e5fd313dac37df2499 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 22 Jun 2012 13:18:05 +0000 Subject: QPID-4075: Raise delete event for autodeleted queues also git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1352874 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/SemanticState.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/broker/SemanticState.cpp') diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp index 5786370598..9a84db547c 100644 --- a/cpp/src/qpid/broker/SemanticState.cpp +++ b/cpp/src/qpid/broker/SemanticState.cpp @@ -72,7 +72,8 @@ SemanticState::SemanticState(DeliveryAdapter& da, SessionContext& ss) dtxSelected(false), authMsg(getSession().getBroker().getOptions().auth && !getSession().getConnection().isUserProxyAuth()), userID(getSession().getConnection().getUserId()), - closeComplete(false) + closeComplete(false), + connectionId(getSession().getConnection().getUrl()) {} SemanticState::~SemanticState() { @@ -428,7 +429,7 @@ void SemanticState::cancel(ConsumerImpl::shared_ptr c) if(queue) { queue->cancel(c); if (queue->canAutoDelete() && !queue->hasExclusiveOwner()) { - Queue::tryAutoDelete(session.getBroker(), queue); + Queue::tryAutoDelete(session.getBroker(), queue, connectionId, userID); } } c->cancel(); -- cgit v1.2.1