[rhmessaging-commits] rhmessaging commits: r2818 - mgmt/trunk/mint/python/mint.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Mon Nov 17 09:27:06 EST 2008
Author: eallen
Date: 2008-11-17 09:27:06 -0500 (Mon, 17 Nov 2008)
New Revision: 2818
Modified:
mgmt/trunk/mint/python/mint/schema.py
Log:
Updated schema.py that allows calls with 0 input arguments.
Modified: mgmt/trunk/mint/python/mint/schema.py
===================================================================
--- mgmt/trunk/mint/python/mint/schema.py 2008-11-17 14:13:02 UTC (rev 2817)
+++ mgmt/trunk/mint/python/mint/schema.py 2008-11-17 14:27:06 UTC (rev 2818)
@@ -175,46 +175,56 @@
def GetAd(self, model, callback, JobAd):
actualArgs = list()
- actualArgs.append(JobAd)
+ if JobAd:
+ actualArgs.append(JobAd)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "GetAd",
callback, args=actualArgs)
def SetAttribute(self, model, callback, Name, Value):
actualArgs = list()
- actualArgs.append(Name)
- actualArgs.append(Value)
+ if Name:
+ actualArgs.append(Name)
+ if Value:
+ actualArgs.append(Value)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "SetAttribute",
callback, args=actualArgs)
def Hold(self, model, callback, Reason):
actualArgs = list()
- actualArgs.append(Reason)
+ if Reason:
+ actualArgs.append(Reason)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "Hold",
callback, args=actualArgs)
def Release(self, model, callback, Reason):
actualArgs = list()
- actualArgs.append(Reason)
+ if Reason:
+ actualArgs.append(Reason)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "Release",
callback, args=actualArgs)
def Remove(self, model, callback, Reason):
actualArgs = list()
- actualArgs.append(Reason)
+ if Reason:
+ actualArgs.append(Reason)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "Remove",
callback, args=actualArgs)
def Fetch(self, model, callback, File, Start, End, Data):
actualArgs = list()
- actualArgs.append(File)
- actualArgs.append(Start)
- actualArgs.append(End)
- actualArgs.append(Data)
+ if File:
+ actualArgs.append(File)
+ if Start:
+ actualArgs.append(Start)
+ if End:
+ actualArgs.append(End)
+ if Data:
+ actualArgs.append(Data)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "Fetch",
callback, args=actualArgs)
@@ -344,15 +354,18 @@
def GetLimits(self, model, callback, Limits):
actualArgs = list()
- actualArgs.append(Limits)
+ if Limits:
+ actualArgs.append(Limits)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "GetLimits",
callback, args=actualArgs)
def SetLimit(self, model, callback, Name, Max):
actualArgs = list()
- actualArgs.append(Name)
- actualArgs.append(Max)
+ if Name:
+ actualArgs.append(Name)
+ if Max:
+ actualArgs.append(Max)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "SetLimit",
callback, args=actualArgs)
@@ -443,14 +456,16 @@
def Start(self, model, callback, Subsystem):
actualArgs = list()
- actualArgs.append(Subsystem)
+ if Subsystem:
+ actualArgs.append(Subsystem)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "Start",
callback, args=actualArgs)
def Stop(self, model, callback, Subsystem):
actualArgs = list()
- actualArgs.append(Subsystem)
+ if Subsystem:
+ actualArgs.append(Subsystem)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "Stop",
callback, args=actualArgs)
@@ -636,7 +651,8 @@
def expand(self, model, callback, by):
"""Increase number of files allocated for this journal"""
actualArgs = list()
- actualArgs.append(by)
+ if by:
+ actualArgs.append(by)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "expand",
callback, args=actualArgs)
@@ -741,8 +757,10 @@
def echo(self, model, callback, sequence, body):
"""Request a response to test the path to the management broker"""
actualArgs = list()
- actualArgs.append(sequence)
- actualArgs.append(body)
+ if sequence:
+ actualArgs.append(sequence)
+ if body:
+ actualArgs.append(body)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "echo",
callback, args=actualArgs)
@@ -750,13 +768,20 @@
def connect(self, model, callback, host, port, durable, authMechanism, username, password, transport):
"""Establish a connection to another broker"""
actualArgs = list()
- actualArgs.append(host)
- actualArgs.append(port)
- actualArgs.append(durable)
- actualArgs.append(authMechanism)
- actualArgs.append(username)
- actualArgs.append(password)
- actualArgs.append(transport)
+ if host:
+ actualArgs.append(host)
+ if port:
+ actualArgs.append(port)
+ if durable:
+ actualArgs.append(durable)
+ if authMechanism:
+ actualArgs.append(authMechanism)
+ if username:
+ actualArgs.append(username)
+ if password:
+ actualArgs.append(password)
+ if transport:
+ actualArgs.append(transport)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "connect",
callback, args=actualArgs)
@@ -764,9 +789,12 @@
def queueMoveMessages(self, model, callback, srcQueue, destQueue, qty):
"""Move messages from one queue to another"""
actualArgs = list()
- actualArgs.append(srcQueue)
- actualArgs.append(destQueue)
- actualArgs.append(qty)
+ if srcQueue:
+ actualArgs.append(srcQueue)
+ if destQueue:
+ actualArgs.append(destQueue)
+ if qty:
+ actualArgs.append(qty)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "queueMoveMessages",
callback, args=actualArgs)
@@ -870,7 +898,8 @@
def purge(self, model, callback, request):
"""Discard all or some messages on a queue"""
actualArgs = list()
- actualArgs.append(request)
+ if request:
+ actualArgs.append(request)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "purge",
callback, args=actualArgs)
@@ -1064,15 +1093,24 @@
def bridge(self, model, callback, durable, src, dest, key, tag, excludes, srcIsQueue, srcIsLocal, dynamic):
"""Bridge messages over the link"""
actualArgs = list()
- actualArgs.append(durable)
- actualArgs.append(src)
- actualArgs.append(dest)
- actualArgs.append(key)
- actualArgs.append(tag)
- actualArgs.append(excludes)
- actualArgs.append(srcIsQueue)
- actualArgs.append(srcIsLocal)
- actualArgs.append(dynamic)
+ if durable:
+ actualArgs.append(durable)
+ if src:
+ actualArgs.append(src)
+ if dest:
+ actualArgs.append(dest)
+ if key:
+ actualArgs.append(key)
+ if tag:
+ actualArgs.append(tag)
+ if excludes:
+ actualArgs.append(excludes)
+ if srcIsQueue:
+ actualArgs.append(srcIsQueue)
+ if srcIsLocal:
+ actualArgs.append(srcIsLocal)
+ if dynamic:
+ actualArgs.append(dynamic)
originalId = ObjectId(None, self.sourceScopeId, self.sourceObjectId)
model.callMethod(self.managedBroker, originalId, self.qmfClassKey, "bridge",
callback, args=actualArgs)
More information about the rhmessaging-commits
mailing list