User: ejort
Date: 02/02/15 12:59:53
Modified: src/main/org/jboss/mq/server JBossMQService.java
MessageCache.java QueueManager.java
TopicManager.java
Log:
Don't use invoke for attributes on the JMX bus
Revision Changes Path
1.14 +7 -13 jbossmq/src/main/org/jboss/mq/server/JBossMQService.java
Index: JBossMQService.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/JBossMQService.java,v
retrieving revision 1.13
retrieving revision 1.14
diff -u -r1.13 -r1.14
--- JBossMQService.java 15 Feb 2002 06:18:29 -0000 1.13
+++ JBossMQService.java 15 Feb 2002 20:59:53 -0000 1.14
@@ -29,7 +29,7 @@
* @author Vincent Sheffer ([EMAIL PROTECTED])
* @author <a href="mailto:[EMAIL PROTECTED]";>Juha Lindfors</a>
* @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a>
- * @version $Revision: 1.13 $
+ * @version $Revision: 1.14 $
*/
public class JBossMQService
extends ServiceMBeanSupport
@@ -167,24 +167,18 @@
MBeanProxy.create(ServiceControllerMBean.class,
ServiceControllerMBean.OBJECT_NAME,
server);
-
+
PersistenceManager pm = (PersistenceManager)
- server.invoke(persistenceManager,
- "getInstance",
- new Object[0],
- new String[0]);
-
+ server.getAttribute(persistenceManager, "Instance");
+
JMSServer.initServer(); // yucky kludge!
-
+
jmsServer = JMSServer.getInstance();
jmsServer.setPersistenceManager(pm);
StateManager sm = (StateManager)
- server.invoke(stateManager,
- "getInstance",
- new Object[0],
- new String[0]);
-
+ server.getAttribute(stateManager, "Instance");
+
jmsServer.setStateManager(sm);
jmsServer.startServer();
1.15 +3 -3 jbossmq/src/main/org/jboss/mq/server/MessageCache.java
Index: MessageCache.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/MessageCache.java,v
retrieving revision 1.14
retrieving revision 1.15
diff -u -r1.14 -r1.15
--- MessageCache.java 13 Feb 2002 04:26:38 -0000 1.14
+++ MessageCache.java 15 Feb 2002 20:59:53 -0000 1.15
@@ -32,7 +32,7 @@
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Hiram Chirino</a>
* @author <a href="mailto:[EMAIL PROTECTED]";>David Maplesden</a>
- * @version $Revision: 1.14 $
+ * @version $Revision: 1.15 $
*/
public class MessageCache
extends ServiceMBeanSupport
@@ -242,8 +242,8 @@
*/
protected void startService() throws Exception
{
-
- cacheStore = (CacheStore)getServer().invoke(cacheStoreObjectName,
"getInstance", new Object[] {}, new String[] {});
+
+ cacheStore = (CacheStore)getServer().getAttribute(cacheStoreObjectName,
"Instance");
if (getState() == ServiceMBeanSupport.STARTED)
throw new Exception("Cannot be initialized from the current state");
1.14 +3 -6 jbossmq/src/main/org/jboss/mq/server/QueueManager.java
Index: QueueManager.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/QueueManager.java,v
retrieving revision 1.13
retrieving revision 1.14
diff -u -r1.13 -r1.14
--- QueueManager.java 13 Feb 2002 07:51:54 -0000 1.13
+++ QueueManager.java 15 Feb 2002 20:59:53 -0000 1.14
@@ -34,7 +34,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a>
- * @version $Revision: 1.13 $
+ * @version $Revision: 1.14 $
*/
public class QueueManager
extends ServiceMBeanSupport
@@ -92,17 +92,14 @@
}
JMSServer jmsServer = (JMSServer)
- server.invoke(jbossMQService,
- "getJMSServer",
- new Object[0],
- new String[0]);
+ server.getAttribute(jbossMQService, "JMSServer");
queue = new SpyQueue(queueName);
destination = new JMSQueue(queue, null, jmsServer);
jmsServer.addDestination(queue, destination);
jmsServer.getPersistenceManager().restoreQueue(destination, queue);
-
+
if (jndiName == null) {
setJNDIName("queue/" + queueName);
}
1.15 +3 -6 jbossmq/src/main/org/jboss/mq/server/TopicManager.java
Index: TopicManager.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/TopicManager.java,v
retrieving revision 1.14
retrieving revision 1.15
diff -u -r1.14 -r1.15
--- TopicManager.java 13 Feb 2002 07:51:54 -0000 1.14
+++ TopicManager.java 15 Feb 2002 20:59:53 -0000 1.15
@@ -37,7 +37,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author <a href="[EMAIL PROTECTED]">Hiram Chirino</a>
- * @version $Revision: 1.14 $
+ * @version $Revision: 1.15 $
*/
public class TopicManager
extends ServiceMBeanSupport
@@ -84,11 +84,8 @@
}
JMSServer jmsServer = (JMSServer)
- server.invoke(jbossMQService,
- "getJMSServer",
- new Object[0],
- new String[0]);
-
+ server.getAttribute(jbossMQService, "JMSServer");
+
topic = new SpyTopic(topicName);
destination = new JMSTopic(topic, null, jmsServer);
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
