[rhmessaging-commits] rhmessaging commits: r4151 - in mgmt/newdata: cumin/python/cumin and 1 other directories.

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2010-07-26 17:37:19 -0400 (Mon, 26 Jul 2010)
New Revision: 4151

Modified:
   mgmt/newdata/cumin/bin/cumin-data
   mgmt/newdata/cumin/python/cumin/config.py
   mgmt/newdata/mint/python/mint/session.py
Log:
Add configuration for binding to a defined set of qmf packages

Modified: mgmt/newdata/cumin/bin/cumin-data
===================================================================
--- mgmt/newdata/cumin/bin/cumin-data	2010-07-26 20:34:27 UTC (rev 4150)
+++ mgmt/newdata/cumin/bin/cumin-data	2010-07-26 21:37:19 UTC (rev 4151)
@@ -25,12 +25,26 @@
     model_dir = os.path.join(config.home, "model")
 
     mint = Mint(model_dir, opts.broker, opts.database)
-
     mint.print_event_level = opts.print_events
 
     mint.check()
     mint.init()
 
+    if values.data.packages:
+        packages = list()
+
+        for name in values.data.packages.split(","):
+            name = name.strip()
+
+            try:
+                pkg = mint.model._packages_by_name[name]
+            except KeyError:
+                print "No package found for '%s'" % name
+
+            packages.append(pkg)
+
+        mint.session.qmf_packages = packages
+
     if opts.init_only:
         return
 

Modified: mgmt/newdata/cumin/python/cumin/config.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/config.py	2010-07-26 20:34:27 UTC (rev 4150)
+++ mgmt/newdata/cumin/python/cumin/config.py	2010-07-26 21:37:19 UTC (rev 4151)
@@ -33,6 +33,8 @@
         data = CuminConfigSection(self, "data")
         data.log_file.default = os.path.join(self.home, "log", "data.log")
 
+        param = ConfigParameter(data, "packages", str)
+
         param = ConfigParameter(data, "expire-frequency", int)
         param.default = 600 # 10 minutes
 

Modified: mgmt/newdata/mint/python/mint/session.py
===================================================================
--- mgmt/newdata/mint/python/mint/session.py	2010-07-26 20:34:27 UTC (rev 4150)
+++ mgmt/newdata/mint/python/mint/session.py	2010-07-26 21:37:19 UTC (rev 4151)
@@ -12,6 +12,7 @@
 
         self.qmf_session = None
         self.qmf_brokers = list()
+        self.qmf_packages = self.app.model._packages
 
     def add_broker(self, uri):
         log.info("Adding QMF broker at %s", uri)
@@ -36,8 +37,12 @@
                                    manageConnections=True,
                                    rcvObjects=self.app.update_enabled,
                                    rcvEvents=False,
-                                   rcvHeartbeats=True)
+                                   rcvHeartbeats=True,
+                                   userBindings=True)
 
+        for pkg in self.app.model._packages:
+            self.qmf_session.bindPackage(pkg._name)
+
         self.add_broker(self.broker_uri)
 
     def stop(self):