org.ow2.jonas.jms
Interface JmsAdministration

public interface JmsAdministration

JMS Administration interface. must be implemented for each jms provider JOnAS uses this interface to access the JMS provider.

Author:

Philippe Coq Contributor(s): Jeff Mesnil: for JORAM 3.0 integration Frederic Maistre: for JORAM 3.4 (JMS 1.1) integration 03/05/25 : Adriana Danes : add JMS resource monitoring

Method Summary

Queue	createQueue(String name) Create a Queue
Topic	createTopic(String name) Create a Topic
void	deleteDestination(String name) Delete a destination.
int	getPendingMessages(Queue queue) Get number of pending messages on a queue
int	getPendingRequests(Queue queue) Get number of pending requests on a queue
int	getSubscriptions(Topic topic) Get number of subscriptions on a topic
XAConnectionFactory	getXAConnectionFactory() Get the XAConnectionFactory
XAQueueConnectionFactory	getXAQueueConnectionFactory() Get the XAQueueConnectionFactory
XATopicConnectionFactory	getXATopicConnectionFactory() Get the XATopicConnectionFactory
void	start(boolean collocated, String url) Jms Administrator is created with newInstance().
void	stop() Stop the Jms Administrator

Method Detail

start

void start(boolean collocated,
           String url)
           throws 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 XAConnectionFactory, a XATopicConnectionFactory and a XAQueueConnectionFactory

Parameters:

boolean - true for if the MOM in run in the current JVM

String - url connexion that must be used.

Throws:

Exception

stop

void stop()

Stop the Jms Administrator

getXAConnectionFactory

XAConnectionFactory getXAConnectionFactory()

Get the XAConnectionFactory

getXATopicConnectionFactory

XATopicConnectionFactory getXATopicConnectionFactory()

Get the XATopicConnectionFactory

getXAQueueConnectionFactory

XAQueueConnectionFactory getXAQueueConnectionFactory()

Get the XAQueueConnectionFactory

createTopic

Topic createTopic(String name)
                  throws Exception

Create a Topic

Throws:

Exception

createQueue

Queue createQueue(String name)
                  throws Exception

Create a Queue

Throws:

Exception

deleteDestination

void deleteDestination(String name)
                       throws Exception

Delete a destination.

Throws:

Exception

getPendingMessages

int getPendingMessages(Queue queue)
                       throws Exception

Get number of pending messages on a queue

Throws:

Exception

getPendingRequests

int getPendingRequests(Queue queue)
                       throws Exception

Get number of pending requests on a queue

Throws:

Exception

getSubscriptions

int getSubscriptions(Topic topic)
                     throws Exception

Get number of subscriptions on a topic

Throws:

Exception