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):
Show replies by date