org.objectweb.jonas_jms
Class JmsAdminForJoram

java.lang.Object
  extended by org.objectweb.jonas_jms.JmsAdminForJoram
All Implemented Interfaces:
JmsAdministration

public class JmsAdminForJoram
extends java.lang.Object
implements JmsAdministration

Joram administration. This JORAM specific class allows to administer a JORAM server when JORAM has been declared as a service.

Author:
Philippe Coq Contributor(s): Philippe Durieux

Jeff Mesnil: for JORAM 3.x integration

Frederic Maistre for JORAM 4.x integration

03/05/25 Adriana Danes : JMS resource monitoring


Constructor Summary
JmsAdminForJoram()
          default constructor.
 
Method Summary
 javax.jms.Queue createQueue(java.lang.String name)
          Create a Queue and bind it to the registry
 javax.jms.Topic createTopic(java.lang.String name)
          Create a Topic and bind it to the registry
 void deleteDestination(java.lang.String name)
          Delete a destination.
 int getPendingMessages(javax.jms.Queue queue)
          Get number of pending messages on a queue
 int getPendingRequests(javax.jms.Queue queue)
          Get number of pending requests on a queue
 int getSubscriptions(javax.jms.Topic topic)
          Get number of subscriptions on a topic
 javax.jms.XAConnectionFactory getXAConnectionFactory()
          Get the XAConnectionFactory
 javax.jms.XAQueueConnectionFactory getXAQueueConnectionFactory()
          Get the XAQueueConnectionFactory
 javax.jms.XATopicConnectionFactory getXATopicConnectionFactory()
          Get the XATopicConnectionFactory
 void start(boolean collocated, java.lang.String url)
          Jms Administrator is created with newInstance().
 void stop()
          Stop the Jms Administrator
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JmsAdminForJoram

public JmsAdminForJoram()
default constructor. This class will be created with newInstance().

Method Detail

start

public void start(boolean collocated,
                  java.lang.String url)
           throws java.lang.Exception
Jms Administrator is created with newInstance(). initialization is done later with this method. The MOM will be started if collocated. This method should create an XATopicConnectionFactory and an XAQueueConnectionFactory

Specified by:
start in interface JmsAdministration
Parameters:
boolean - true for if the MOM in run in the current JVM
String - url connexion that must be used if not collocated
Throws:
java.lang.Exception

stop

public void stop()
Stop the Jms Administrator

Specified by:
stop in interface JmsAdministration

getXAConnectionFactory

public javax.jms.XAConnectionFactory getXAConnectionFactory()
Get the XAConnectionFactory

Specified by:
getXAConnectionFactory in interface JmsAdministration

getXATopicConnectionFactory

public javax.jms.XATopicConnectionFactory getXATopicConnectionFactory()
Get the XATopicConnectionFactory

Specified by:
getXATopicConnectionFactory in interface JmsAdministration

getXAQueueConnectionFactory

public javax.jms.XAQueueConnectionFactory getXAQueueConnectionFactory()
Get the XAQueueConnectionFactory

Specified by:
getXAQueueConnectionFactory in interface JmsAdministration

createQueue

public javax.jms.Queue createQueue(java.lang.String name)
                            throws java.lang.Exception
Create a Queue and bind it to the registry

Specified by:
createQueue in interface JmsAdministration
Throws:
java.lang.Exception

createTopic

public javax.jms.Topic createTopic(java.lang.String name)
                            throws java.lang.Exception
Create a Topic and bind it to the registry

Specified by:
createTopic in interface JmsAdministration
Throws:
java.lang.Exception

deleteDestination

public void deleteDestination(java.lang.String name)
                       throws java.lang.Exception
Delete a destination.

Specified by:
deleteDestination in interface JmsAdministration
Throws:
java.lang.Exception

getPendingMessages

public int getPendingMessages(javax.jms.Queue queue)
                       throws java.lang.Exception
Get number of pending messages on a queue

Specified by:
getPendingMessages in interface JmsAdministration
Parameters:
queue - the monitored queue
Throws:
java.lang.Exception - if could not get info (queue not valid or connection failed or monitoring request failed)

getPendingRequests

public int getPendingRequests(javax.jms.Queue queue)
                       throws java.lang.Exception
Get number of pending requests on a queue

Specified by:
getPendingRequests in interface JmsAdministration
Parameters:
queue - the monitored queue
Throws:
java.lang.Exception - if could not get info (queue not valid or connection failed or monitoring request failed)

getSubscriptions

public int getSubscriptions(javax.jms.Topic topic)
                     throws java.lang.Exception
Get number of subscriptions on a topic

Specified by:
getSubscriptions in interface JmsAdministration
Parameters:
topic - the monitored topic
Throws:
java.lang.Exception - if could not get info (topic not valid or connection failed or monitoring request failed)