|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.objectweb.jonas_jms.JmsManagerImpl
JmsManager implementation This singleton class must exist in each JOnAS server that want to use JMS
Christophe Ney: for making easier Enhydra integration
Philippe Durieux
Jeff Mesnil: for JORAM 3.0 integration
Philippe Coq: for JORAM 3.1 (JMS 1.1) integration
Adriana Danes : update with support of JMS resource monitoring
Method Summary | |
javax.jms.Queue |
createQueue(java.lang.String name)
Creation of an administered Object Queue and bind it in the registry |
javax.jms.Topic |
createTopic(java.lang.String name)
Creation of an administered Object Topic and bind it in the registry |
javax.jms.ConnectionFactory |
getConnectionFactory()
Get the unique ConnectionFactory |
java.lang.String |
getConnectionFactoryMode(java.lang.String jndiName)
Get the messaging mode a connection factory belongs to |
int |
getCurrentNumberOfJmsConnectionFactory()
Management method |
int |
getCurrentNumberOfJmsQueueConnectionFactory()
Management method |
int |
getCurrentNumberOfJmsQueueDestination()
Management method |
int |
getCurrentNumberOfJmsTopicConnectionFactory()
Management method |
int |
getCurrentNumberOfJmsTopicDestination()
Management method |
java.lang.String |
getDefaultConnectionFactoryName()
Management method |
java.lang.String |
getDefaultQueueConnectionFactoryName()
Management method |
java.lang.String |
getDefaultTopicConnectionFactoryName()
Management method |
static JmsJmxManagement |
getJmsJmxManagement()
Get the JmsJmxManagement. |
static JmsManager |
getJmsManager()
Get the JmsManager. |
int |
getPendingMessages(java.lang.String jndiName)
Get number of pending messages on a queue |
int |
getPendingRequests(java.lang.String jndiName)
Get number of pending requests on a queue |
javax.jms.Queue |
getQueue(java.lang.String name)
Get Queue (creates it if not exist) |
javax.jms.QueueConnectionFactory |
getQueueConnectionFactory()
Get the unique QueueConnectionFactory |
java.util.Enumeration |
getQueuesNames()
Get Queue Names |
int |
getSubscriptions(java.lang.String jndiName)
Get number of subscriptions on a topic |
javax.jms.Topic |
getTopic(java.lang.String name)
Get Topic (creates it if not exist) |
javax.jms.TopicConnectionFactory |
getTopicConnectionFactory()
Get the unique TopicConnectionFactory |
java.util.Enumeration |
getTopicsNames()
Get Topic Names |
static org.objectweb.transaction.jta.TransactionManager |
getTransactionManager()
return the Transaction Manager |
javax.jms.XAConnectionFactory |
getXAConnectionFactory()
Get Default XAConnectionFactory |
javax.jms.XAQueueConnectionFactory |
getXAQueueConnectionFactory()
Get Default XAQueueConnectionFactory |
javax.jms.XATopicConnectionFactory |
getXATopicConnectionFactory()
Get Default XATopicConnectionFactory |
void |
init(java.lang.Class cl,
boolean collocated,
java.lang.String url,
org.objectweb.transaction.jta.TransactionManager trm)
Initialization of the JmsManager |
java.lang.String |
removeJmsDestination(java.lang.String jndiName)
Remove a Jms destination |
void |
stop()
Terminate the administering process |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
public static JmsManager getJmsManager()
public static JmsJmxManagement getJmsJmxManagement()
public static org.objectweb.transaction.jta.TransactionManager getTransactionManager()
public void init(java.lang.Class cl, boolean collocated, java.lang.String url, org.objectweb.transaction.jta.TransactionManager trm) throws java.lang.Exception
init
in interface JmsManager
java.lang.Exception
- must be thrown if the MOM is unreachablepublic javax.jms.Queue createQueue(java.lang.String name) throws java.lang.Exception
createQueue
in interface JmsManager
java.lang.Exception
public javax.jms.Topic createTopic(java.lang.String name) throws java.lang.Exception
createTopic
in interface JmsManager
java.lang.Exception
public javax.jms.ConnectionFactory getConnectionFactory()
getConnectionFactory
in interface JmsManager
public javax.jms.TopicConnectionFactory getTopicConnectionFactory()
getTopicConnectionFactory
in interface JmsManager
public javax.jms.QueueConnectionFactory getQueueConnectionFactory()
JmsManager
getQueueConnectionFactory
in interface JmsManager
public javax.jms.XAConnectionFactory getXAConnectionFactory()
getXAConnectionFactory
in interface JmsManager
public javax.jms.XATopicConnectionFactory getXATopicConnectionFactory()
getXATopicConnectionFactory
in interface JmsManager
public javax.jms.XAQueueConnectionFactory getXAQueueConnectionFactory()
getXAQueueConnectionFactory
in interface JmsManager
public javax.jms.Queue getQueue(java.lang.String name) throws java.lang.Exception
getQueue
in interface JmsManager
java.lang.Exception
public javax.jms.Topic getTopic(java.lang.String name) throws java.lang.Exception
getTopic
in interface JmsManager
java.lang.Exception
public java.util.Enumeration getTopicsNames()
getTopicsNames
in interface JmsManager
public java.util.Enumeration getQueuesNames()
getQueuesNames
in interface JmsManager
public void stop() throws java.lang.Exception
stop
in interface JmsManager
java.lang.Exception
public int getCurrentNumberOfJmsConnectionFactory()
JmsJmxManagement
getCurrentNumberOfJmsConnectionFactory
in interface JmsJmxManagement
public int getCurrentNumberOfJmsTopicConnectionFactory()
JmsJmxManagement
getCurrentNumberOfJmsTopicConnectionFactory
in interface JmsJmxManagement
public int getCurrentNumberOfJmsQueueConnectionFactory()
JmsJmxManagement
getCurrentNumberOfJmsQueueConnectionFactory
in interface JmsJmxManagement
public int getCurrentNumberOfJmsTopicDestination()
JmsJmxManagement
getCurrentNumberOfJmsTopicDestination
in interface JmsJmxManagement
public int getCurrentNumberOfJmsQueueDestination()
JmsJmxManagement
getCurrentNumberOfJmsQueueDestination
in interface JmsJmxManagement
public java.lang.String removeJmsDestination(java.lang.String jndiName) throws java.lang.Exception
removeJmsDestination
in interface JmsJmxManagement
java.lang.Exception
public java.lang.String getDefaultConnectionFactoryName()
JmsJmxManagement
getDefaultConnectionFactoryName
in interface JmsJmxManagement
public java.lang.String getDefaultQueueConnectionFactoryName()
JmsJmxManagement
getDefaultQueueConnectionFactoryName
in interface JmsJmxManagement
public java.lang.String getDefaultTopicConnectionFactoryName()
JmsJmxManagement
getDefaultTopicConnectionFactoryName
in interface JmsJmxManagement
public java.lang.String getConnectionFactoryMode(java.lang.String jndiName) throws java.lang.Exception
getConnectionFactoryMode
in interface JmsJmxManagement
jndiName
- connection factory name
failure
- on calling monitoring operation
java.lang.Exception
public int getPendingMessages(java.lang.String jndiName) throws java.lang.Exception
getPendingMessages
in interface JmsJmxManagement
jndiName
- queue name
failure
- on calling monitoring operation
java.lang.Exception
public int getPendingRequests(java.lang.String jndiName) throws java.lang.Exception
getPendingRequests
in interface JmsJmxManagement
jndiName
- queue name
failure
- on calling monitoring operation
java.lang.Exception
public int getSubscriptions(java.lang.String jndiName) throws java.lang.Exception
getSubscriptions
in interface JmsJmxManagement
jndiName
- topic name
failure
- on calling monitoring operation
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |