From d4146cce3f6c11636f0bf8e693db26244411a371 Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Wed, 24 Jan 2007 17:30:39 +0000 Subject: QPID-50 : Patch supplied by Rob Godfrey - Virtual Host implementation git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@499493 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/protocol/AMQMinaProtocolSession.java | 11 ++++++----- .../org/apache/qpid/server/protocol/AMQProtocolSession.java | 2 +- 2 files changed, 7 insertions(+), 6 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java index 9ca11abb56..8cc747200f 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java @@ -112,8 +112,8 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, _codecFactory = codecFactory; - _managedObject = createMBean(); - _managedObject.register(); + + // this(session, queueRegistry, exchangeRegistry, codecFactory, new AMQStateManager()); } @@ -127,8 +127,7 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, _codecFactory = codecFactory; - _managedObject = createMBean(); - _managedObject.register(); + } private AMQProtocolSessionMBean createMBean() throws AMQException @@ -567,9 +566,11 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, return _virtualHost; } - public void setVirtualHost(VirtualHost virtualHost) + public void setVirtualHost(VirtualHost virtualHost) throws AMQException { _virtualHost = virtualHost; + _managedObject = createMBean(); + _managedObject.register(); } public void addSessionCloseTask(Task task) diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java index ee7e46eba4..48c05058b0 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java @@ -137,7 +137,7 @@ public interface AMQProtocolSession extends AMQProtocolWriter VirtualHost getVirtualHost(); - void setVirtualHost(VirtualHost virtualHost); + void setVirtualHost(VirtualHost virtualHost) throws AMQException; void addSessionCloseTask(Task task); -- cgit v1.2.1