com.communote.plugins.mq.adapter.activemq

Class ActiveMQAdapter

java.lang.Object

com.communote.plugins.mq.adapter.activemq.ActiveMQAdapter

All Implemented Interfaces:

JMSAdapter

public class ActiveMQAdapter
extends Object
implements JMSAdapter

iPojo component intended for abstracting ActiveMQ provider from the CNT MQ plug-in. It is used in conjunction with JMS adapter plug-in, that provides JMSAdapter interface.

Author:

Communote GmbH - http://www.communote.com/

Field Summary

Fields inherited from interface com.communote.plugins.mq.provider.jms.JMSAdapter

MESSAGE_PROPERTY_TRUST_USER

Constructor Summary

Constructors

Constructor and Description
ActiveMQAdapter()

Method Summary

Modifier and Type	Method and Description
javax.jms.Queue	getDestination()
javax.jms.ConnectionFactory	getFactory()
javax.jms.Session	getSession() returns a Session object
void	initAdapter() Validate call back.
void	onStart() Starting the adapter by setting the callback on the configuration and then start it
void	onStop() Stopping the adapter
void	setConnection(javax.jms.Connection connection) Only for test purposes.
void	stopAdapter() stops active mq adapter

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveMQAdapter

public ActiveMQAdapter()

Method Detail

getDestination

public javax.jms.Queue getDestination()
                               throws javax.jms.JMSException

Specified by:

getDestination in interface JMSAdapter

Returns:

destination

Throws:

javax.jms.JMSException - exception

getFactory

public javax.jms.ConnectionFactory getFactory()

Returns:

get the connection factory

getSession

public javax.jms.Session getSession()
                             throws javax.jms.JMSException

Description copied from interface: JMSAdapter

returns a Session object

Specified by:

getSession in interface JMSAdapter

Returns:

created session instance

Throws:

javax.jms.JMSException - exception

initAdapter

public void initAdapter()

Validate call back. Is used to initialize connection to the ActiveMQ broker.

onStart

public void onStart()

Starting the adapter by setting the callback on the configuration and then start it

onStop

public void onStop()
            throws javax.jms.JMSException

Stopping the adapter

Throws:

javax.jms.JMSException - in case stopping failed

setConnection

public void setConnection(javax.jms.Connection connection)

Only for test purposes.

Parameters:

connection - connection instance to be set

stopAdapter

public void stopAdapter()
                 throws javax.jms.JMSException

stops active mq adapter

Throws:

javax.jms.JMSException - exception