[rhmessaging-commits] rhmessaging commits: r977 - mgmt/cumin/python/cumin.

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2007-10-09 11:41:40 -0400 (Tue, 09 Oct 2007)
New Revision: 977

Modified:
   mgmt/cumin/python/cumin/demo.py
Log:
In the demo data, makes cluster vhost config consistent with cluster
server vhost config.



Modified: mgmt/cumin/python/cumin/demo.py
===================================================================
--- mgmt/cumin/python/cumin/demo.py	2007-10-09 15:36:05 UTC (rev 976)
+++ mgmt/cumin/python/cumin/demo.py	2007-10-09 15:41:40 UTC (rev 977)
@@ -49,6 +49,9 @@
                 vhost.name = cluster.name + "." + name
                 vhost.set_cluster(cluster)
 
+            for vhost in cluster.virtual_host_items():
+                self.load_vhost(vhost)
+
         for server_count in range(12):
             cluster = clusters[server_count % 3]
             
@@ -72,22 +75,25 @@
                 vhost.set_server(server)
 
             for vhost in server.virtual_host_items():
-                for name in ("realm0", "realm1", "realm2"):
-                    realm = Realm(self.model)
-                    realm.name = name
-                    vhost.add_realm(realm)
+                self.load_vhost(vhost)
 
-                for name in ("amq.direct", "amq.fanout",
-                             "amq.topic", "amq.match"):
-                    exchange = Exchange(self.model)
-                    exchange.name = name
-                    vhost.add_exchange(exchange)
+    def load_vhost(self, vhost):
+        for name in ("realm0", "realm1", "realm2"):
+            realm = Realm(self.model)
+            realm.name = name
+            vhost.add_realm(realm)
 
-                for queue_count in range(10):
-                    queue = Queue(self.model)
-                    queue.name = fmt("queue", queue_count)
-                    vhost.add_queue(queue)
+        for name in ("amq.direct", "amq.fanout",
+                     "amq.topic", "amq.match"):
+            exchange = Exchange(self.model)
+            exchange.name = name
+            vhost.add_exchange(exchange)
 
+        for queue_count in range(10):
+            queue = Queue(self.model)
+            queue.name = fmt("queue", queue_count)
+            vhost.add_queue(queue)
+
     def start_updates(self):
         thread = UpdateThread(self.model)
         thread.start()