Author: tmckay
Date: 2013-01-18 22:41:44 +0000 (Fri, 18 Jan 2013)
New Revision: 5661
Modified:
branches/tmckay/sage/python/sage/aviary/aviaryoperations.py
Log:
Add skeleton collector method type
Modified: branches/tmckay/sage/python/sage/aviary/aviaryoperations.py
===================================================================
--- branches/tmckay/sage/python/sage/aviary/aviaryoperations.py 2013-01-18 22:24:28 UTC
(rev 5660)
+++ branches/tmckay/sage/python/sage/aviary/aviaryoperations.py 2013-01-18 22:41:44 UTC
(rev 5661)
@@ -1229,6 +1229,35 @@
self.client_pool.return_object(client)
return res;
+class _AviaryCollectorMethods(_AviaryCommon):
+ def __init__(self, locator, transports, datadir, collector_servers):
+
+ resource = "COLLECTOR"
+ subtype = ""
+ if locator:
+ servers = ServerList(locator,
+ resource, subtype)
+ elif collector_servers and type(collector_servers) == str:
+ servers = FixedServerList(collector_servers,
+ "9000",
+ "/services/collector/",
+ resource,
+ subtype)
+ else:
+ servers = None
+
+ wsdl = "file:" + os.path.join(get_datadir(datadir,
"collector"),
+ "aviary-collector.wsdl")
+
+ super(_AviaryCollectorMethods, self).__init__(transports,
+ servers,
+ wsdl,
+ resource,
+ subtype)
+
+ # Equivalence? We don't want no stinking QMF structural equivalence!
+ self.use_MethodResult_for_sync_calls = False
+
class AviaryOperations(Catalog):
def __init__(self, name, datadir,
locator_uri="",
@@ -1268,6 +1297,11 @@
self.mechs.append(_AviaryHadoopMethods(self.locator,
transports,
datadir, hadoop_servers))
+
+ if collector_servers:
+ self.mechs.append(_AviaryCollectorMethods(self.locator,
+ transports,
+ datadir, collector_servers))
self.add_mechanisms(self.mechs)
def get_hosts(self, resource, subtype=""):
Show replies by date