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

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()