Package org.apache.activemq.artemis.ra.inflow

Class ActiveMQActivation

java.lang.Object

org.apache.activemq.artemis.ra.inflow.ActiveMQActivation

public class ActiveMQActivation
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final Method	ONMESSAGE

Constructor Summary

Constructors

Constructor	Description
ActiveMQActivation(ActiveMQResourceAdapter ra, MessageEndpointFactory endpointFactory, ActiveMQActivationSpec spec)	Constructor

Method Summary

Modifier and Type	Method	Description
ActiveMQActivationSpec	getActivationSpec()
SimpleString	getAddress()
ActiveMQConnectionFactory	getConnectionFactory()
MessageEndpointFactory	getMessageEndpointFactory()
SimpleString	getTopicTemporaryQueue()
WorkManager	getWorkManager()
List<XAResource>	getXAResources()	Returns the list of XAResources for this activation endpoint.
boolean	isDeliveryTransacted()
boolean	isTopic()
void	reconnect(Throwable failure, boolean useInterrupt)	Drops all existing connection-related resources and reconnects
void	setTopicTemporaryQueue(SimpleString topicTemporaryQueue)
protected void	setup()	Setup the activation
protected void	setupCF()
protected void	setupDestination()
protected ClientSession	setupSession(ClientSessionFactory cf)	Setup a session
void	start()	Start the activation
void	startReconnectThread(String cause)
void	stop()	Stop the activation
protected void	teardown(boolean useInterrupt)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

ONMESSAGE

public static final Method ONMESSAGE

Constructor Details

ActiveMQActivation

public ActiveMQActivation(ActiveMQResourceAdapter ra,
 MessageEndpointFactory endpointFactory,
 ActiveMQActivationSpec spec)
                   throws ResourceException

Constructor

Parameters:

ra - The resource adapter

endpointFactory - The endpoint factory

spec - The activation spec

Throws:

ResourceException - Thrown if an error occurs

Method Details

getActivationSpec

public ActiveMQActivationSpec getActivationSpec()

getMessageEndpointFactory

public MessageEndpointFactory getMessageEndpointFactory()

isDeliveryTransacted

public boolean isDeliveryTransacted()

getWorkManager

public WorkManager getWorkManager()

isTopic

public boolean isTopic()

start

public void start()
           throws ResourceException

Start the activation

Throws:

ResourceException - Thrown if an error occurs

getTopicTemporaryQueue

public SimpleString getTopicTemporaryQueue()

setTopicTemporaryQueue

public void setTopicTemporaryQueue(SimpleString topicTemporaryQueue)

getXAResources

public List<XAResource> getXAResources()

Returns the list of XAResources for this activation endpoint.

Returns:

the list of XAResources for this activation endpoint

stop

public void stop()

Stop the activation

setup

protected void setup()
              throws Exception

Setup the activation

Throws:

Exception - Thrown if an error occurs

teardown

protected void teardown(boolean useInterrupt)

setupCF

protected void setupCF()
                throws Exception

Throws:

Exception

setupSession

protected ClientSession setupSession(ClientSessionFactory cf)
                              throws Exception

Setup a session

Returns:

The connection

Throws:

Exception - Thrown if an error occurs

getAddress

public SimpleString getAddress()

setupDestination

protected void setupDestination()
                         throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

startReconnectThread

public void startReconnectThread(String cause)

reconnect

public void reconnect(Throwable failure,
 boolean useInterrupt)

Drops all existing connection-related resources and reconnects

Parameters:

failure - if reconnecting in the event of a failure

getConnectionFactory

public ActiveMQConnectionFactory getConnectionFactory()