[rhmessaging-commits] rhmessaging commits: r1664 - mgmt/mint/python/mint.

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2008-02-07 17:31:41 -0500 (Thu, 07 Feb 2008)
New Revision: 1664

Modified:
   mgmt/mint/python/mint/schema.py
Log:
Quick fix for method problem.



Modified: mgmt/mint/python/mint/schema.py
===================================================================
--- mgmt/mint/python/mint/schema.py	2008-02-07 21:17:30 UTC (rev 1663)
+++ mgmt/mint/python/mint/schema.py	2008-02-07 22:31:41 UTC (rev 1664)
@@ -54,13 +54,13 @@
     actualArgs = dict()
     actualArgs["clusterName"] = clusterName
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "joinCluster", args=actualArgs, packageName="qpid")
 
   def leaveCluster(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "leaveCluster", args=actualArgs, packageName="qpid")
 
   def echo(self, model, managedBroker, callbackMethod, sequence, body):
@@ -69,7 +69,7 @@
     actualArgs["sequence"] = sequence
     actualArgs["body"] = body
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "echo", args=actualArgs, packageName="qpid")
 
 System.sqlmeta.addJoin(SQLMultipleJoin('Broker', joinMethodName='brokers'))
@@ -135,7 +135,7 @@
     """Discard all messages on queue"""
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "purge", args=actualArgs, packageName="qpid")
 
 Vhost.sqlmeta.addJoin(SQLMultipleJoin('Queue', joinMethodName='queues'))
@@ -284,7 +284,7 @@
   def close(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "close", args=actualArgs, packageName="qpid")
 
 Vhost.sqlmeta.addJoin(SQLMultipleJoin('Client', joinMethodName='clients'))
@@ -327,25 +327,25 @@
   def solicitAck(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "solicitAck", args=actualArgs, packageName="qpid")
 
   def detach(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "detach", args=actualArgs, packageName="qpid")
 
   def resetLifespan(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "resetLifespan", args=actualArgs, packageName="qpid")
 
   def close(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "close", args=actualArgs, packageName="qpid")
 
 Vhost.sqlmeta.addJoin(SQLMultipleJoin('Session', joinMethodName='sessions'))
@@ -386,19 +386,19 @@
     actualArgs = dict()
     actualArgs["strength"] = strength
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "throttle", args=actualArgs, packageName="qpid")
 
   def stop(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "stop", args=actualArgs, packageName="qpid")
 
   def start(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "start", args=actualArgs, packageName="qpid")
 
 Session.sqlmeta.addJoin(SQLMultipleJoin('Destination', joinMethodName='destinations'))
@@ -469,7 +469,7 @@
   def close(self, model, managedBroker, callbackMethod):
     actualArgs = dict()
     methodId = model.registerCallback(callbackMethod)
-    model.managedBroker.method(methodId, self.idOriginal, \
+    model.connectedBrokers[managedBroker].managedBroker.method(methodId, self.idOriginal, \
       classToSchemaNameMap[self.__class__.__name__], "close", args=actualArgs, packageName="qpid")
 
 Destination.sqlmeta.addJoin(SQLMultipleJoin('Consumer', joinMethodName='consumers'))