From 36cfeb13b8ad4b532f7f9c2b48ac2353e6217bcd Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Mon, 31 Mar 2008 12:51:36 +0000
Subject: Re-introduced old 'no-local' behaviour for exclusive queues via a
 proprietary arg to queue.declare.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@642981 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/broker/SessionAdapter.cpp | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'cpp/src/qpid/broker/SessionAdapter.cpp')

diff --git a/cpp/src/qpid/broker/SessionAdapter.cpp b/cpp/src/qpid/broker/SessionAdapter.cpp
index 2091e97584..3daf15f269 100644
--- a/cpp/src/qpid/broker/SessionAdapter.cpp
+++ b/cpp/src/qpid/broker/SessionAdapter.cpp
@@ -23,6 +23,7 @@
 #include "qpid/Exception.h"
 #include "qpid/framing/reply_exceptions.h"
 #include "qpid/framing/constants.h"
+#include "qpid/log/Statement.h"
 #include <boost/format.hpp>
 #include <boost/cast.hpp>
 #include <boost/bind.hpp>
@@ -198,6 +199,12 @@ SessionAdapter::QueueHandlerImpl::~QueueHandlerImpl()
         exclusiveQueues.erase(exclusiveQueues.begin());
     }
 }
+    
+bool SessionAdapter::QueueHandlerImpl::isLocal(const ConnectionToken* t) const 
+{ 
+    return session.isLocal(t); 
+}
+
 
 Queue010QueryResult SessionAdapter::QueueHandlerImpl::query(const string& name)
 {
-- 
cgit v1.2.1