You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2007/01/24 17:24:44 UTC

svn commit: r499466 - /incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java

Author: rgreig
Date: Wed Jan 24 08:24:43 2007
New Revision: 499466

URL: http://svn.apache.org/viewvc?view=rev&rev=499466
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/virtualhost/VirtualHost.java

Modified: incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java?view=diff&rev=499466&r1=499465&r2=499466
==============================================================================
--- incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java (original)
+++ incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java Wed Jan 24 08:24:43 2007
@@ -85,7 +85,23 @@
         } // End of MBean class
 
 
+    public VirtualHost(String name, MessageStore store) throws Exception
+    {
+        _name = name;
 
+        _virtualHostMBean = new VirtualHostMBean();
+        _virtualHostMBean.register();
+
+        _queueRegistry = new DefaultQueueRegistry(this);
+        _exchangeFactory = new DefaultExchangeFactory(this);
+        _exchangeRegistry = new DefaultExchangeRegistry(_exchangeFactory);
+
+        _messageStore = store;
+
+        _brokerMBean = new AMQBrokerManagerMBean(_virtualHostMBean);
+        _brokerMBean.register();
+
+    }
     public VirtualHost(String name, Configuration hostConfig) throws Exception
     {
         _name = name;