summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins/management-amqp
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-02-21 01:15:30 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-02-21 01:15:30 +0000
commit7e6f4149a73c4347475caa362f50e4e97d697e2d (patch)
treea594a4ba22e59090ce699900f5a78d0c39eaac3a /qpid/java/broker-plugins/management-amqp
parent344ca0282a94ff5dc364a25186593249bbd478d8 (diff)
downloadqpid-python-7e6f4149a73c4347475caa362f50e4e97d697e2d.tar.gz
QPID-5567 : Move acl checks into the objects being created
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1570411 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/management-amqp')
-rw-r--r--qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNodeConsumer.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNodeConsumer.java b/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNodeConsumer.java
index 008f16883a..1e2c7b0652 100644
--- a/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNodeConsumer.java
+++ b/qpid/java/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNodeConsumer.java
@@ -22,6 +22,7 @@ package org.apache.qpid.server.management.amqp;
import org.apache.qpid.server.consumer.Consumer;
import org.apache.qpid.server.consumer.ConsumerTarget;
+import org.apache.qpid.server.message.MessageSource;
import org.apache.qpid.server.message.internal.InternalMessage;
import org.apache.qpid.server.protocol.AMQSessionModel;
import org.apache.qpid.server.util.StateChangeListener;
@@ -88,8 +89,9 @@ class ManagementNodeConsumer implements Consumer
}
@Override
- public void setNoLocal(final boolean noLocal)
+ public MessageSource getMessageSource()
{
+ return _managementNode;
}
@Override