svn commit: r499493 - in /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol: AMQMinaProtocolSession.java AMQProtocolSession.java

[rgreig]

Author: rgreig
Date: Wed Jan 24 09:30:39 2007
New Revision: 499493

URL: http://svn.apache.org/viewvc?view=rev&rev=499493
Log:
QPID-50 : Patch supplied by Rob Godfrey - Virtual Host implementation

Modified:
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java?view=diff&rev=499493&r1=499492&r2=499493
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
 Wed Jan 24 09:30:39 2007
@@ -112,8 +112,8 @@
 
 
         _codecFactory = codecFactory;
-        _managedObject = createMBean();
-        _managedObject.register();
+
+
 //        this(session, queueRegistry, exchangeRegistry, codecFactory, new 
AMQStateManager());
     }
 
@@ -127,8 +127,7 @@
         
 
         _codecFactory = codecFactory;
-        _managedObject = createMBean();
-        _managedObject.register();
+
     }
 
     private AMQProtocolSessionMBean createMBean() throws AMQException
@@ -567,9 +566,11 @@
         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)

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java?view=diff&rev=499493&r1=499492&r2=499493
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
 Wed Jan 24 09:30:39 2007
@@ -137,7 +137,7 @@
 
     VirtualHost getVirtualHost();
 
-    void setVirtualHost(VirtualHost virtualHost);
+    void setVirtualHost(VirtualHost virtualHost) throws AMQException;
 
     void addSessionCloseTask(Task task);