diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-02-05 16:57:13 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-02-05 16:57:13 +0000 |
| commit | bd07d83c4664c5190af7c52ededbcd57738c4e1e (patch) | |
| tree | 768fa93812886a7c68b435a953ade98c7b5aa87c | |
| parent | 00b7d74269454f15cbe90d790e653887c67bc7cb (diff) | |
| download | qpid-python-bd07d83c4664c5190af7c52ededbcd57738c4e1e.tar.gz | |
Add access to the virtual host to the system node creators
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-amqp-1-0-management@1564828 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/broker-core/src/main/java/org/apache/qpid/server/plugin/SystemNodeCreator.java | 3 | ||||
| -rw-r--r-- | java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java | 7 |
2 files changed, 10 insertions, 0 deletions
diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/plugin/SystemNodeCreator.java b/java/broker-core/src/main/java/org/apache/qpid/server/plugin/SystemNodeCreator.java index 219332a413..a117524254 100644 --- a/java/broker-core/src/main/java/org/apache/qpid/server/plugin/SystemNodeCreator.java +++ b/java/broker-core/src/main/java/org/apache/qpid/server/plugin/SystemNodeCreator.java @@ -21,6 +21,7 @@ package org.apache.qpid.server.plugin; import org.apache.qpid.server.message.MessageNode; +import org.apache.qpid.server.virtualhost.VirtualHost; public interface SystemNodeCreator extends Pluggable { @@ -28,6 +29,8 @@ public interface SystemNodeCreator extends Pluggable { void registerSystemNode(MessageNode node); void removeSystemNode(MessageNode node); + + VirtualHost getVirtualHost(); } void register(SystemNodeRegistry registry); diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java b/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java index 948afea4a3..9a23e00f90 100644 --- a/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java +++ b/java/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java @@ -983,6 +983,7 @@ public abstract class AbstractVirtualHost implements VirtualHost, IConnectionReg } } + @Override public void removeSystemNode(final MessageNode node) { if(node instanceof MessageDestination) @@ -994,5 +995,11 @@ public abstract class AbstractVirtualHost implements VirtualHost, IConnectionReg _systemNodeSources.remove(node.getName()); } } + + @Override + public VirtualHost getVirtualHost() + { + return AbstractVirtualHost.this; + } } } |