org.wso2.carbon.event.input.adapter.jms.internal.util

Class JMSListener

java.lang.Object

org.wso2.carbon.event.input.adapter.jms.internal.util.JMSListener

All Implemented Interfaces:

Runnable

public class JMSListener
extends Object
implements Runnable

The revamped JMS Transport listener implementation. Creates JMSTaskManager instances for each service requesting exposure over JMS, and stops these if they are undeployed / stopped.

A service indicates a JMS Connection factory definition by name, which would be defined in the JMSListner on the axis2.xml, and this provides a way to reuse common configuration between services, as well as to optimize resources utilized

If the connection factory name was not specified, it will default to the one named "default" JMSConstants.DEFAULT_CONFAC_NAME

If a destination JNDI name is not specified, a service will expect to use a Queue with the same JNDI name as of the service. Additional Parameters allows one to bind to a Topic or specify many more detailed control options. See package documentation for more details

All Destinations / JMS Administered objects used MUST be pre-created or already available

Constructor Summary

Constructors

Constructor and Description
JMSListener(String listenerName, JMSTaskManager jmsTaskManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	run() When an object implementing interface Runnable is used to create a thread, starting the thread causes the object's run method to be called in that separately executing thread.
void	startListener()
void	stopListener() Stops listening for messages for the service thats undeployed or stopped

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSListener

public JMSListener(String listenerName,
           JMSTaskManager jmsTaskManager)

Method Detail

stopListener

public void stopListener()

Stops listening for messages for the service thats undeployed or stopped

run

public void run()

When an object implementing interface Runnable is used to create a thread, starting the thread causes the object's run method to be called in that separately executing thread.

The general contract of the method run is that it may take any action whatsoever.

Specified by:

run in interface Runnable

See Also:

Thread.run()

startListener

public void startListener()