public class ActiveMQActivation extends Object
Modifier and Type | Field and Description |
---|---|
static Method |
ONMESSAGE
The onMessage method
|
Constructor and Description |
---|
ActiveMQActivation(ActiveMQResourceAdapter ra,
javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
ActiveMQActivationSpec spec)
Constructor
|
Modifier and Type | Method and Description |
---|---|
ActiveMQActivationSpec |
getActivationSpec()
Get the activation spec
|
SimpleString |
getAddress() |
ActiveMQConnectionFactory |
getConnectionFactory() |
javax.resource.spi.endpoint.MessageEndpointFactory |
getMessageEndpointFactory()
Get the message endpoint factory
|
SimpleString |
getTopicTemporaryQueue() |
javax.resource.spi.work.WorkManager |
getWorkManager()
Get the work manager
|
List<XAResource> |
getXAResources() |
boolean |
isDeliveryTransacted()
Get whether delivery is transacted
|
boolean |
isTopic()
Is the destination a topic
|
void |
reconnect(Throwable failure)
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 threadName) |
void |
stop()
Stop the activation
|
protected void |
teardown()
Teardown the activation
|
String |
toString()
Get a string representation
|
public static final Method ONMESSAGE
public ActiveMQActivation(ActiveMQResourceAdapter ra, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, ActiveMQActivationSpec spec) throws javax.resource.ResourceException
ra
- The resource adapterendpointFactory
- The endpoint factoryspec
- The activation specjavax.resource.ResourceException
- Thrown if an error occurspublic ActiveMQActivationSpec getActivationSpec()
public javax.resource.spi.endpoint.MessageEndpointFactory getMessageEndpointFactory()
public boolean isDeliveryTransacted()
public javax.resource.spi.work.WorkManager getWorkManager()
public boolean isTopic()
public void start() throws javax.resource.ResourceException
javax.resource.ResourceException
- Thrown if an error occurspublic SimpleString getTopicTemporaryQueue()
public void setTopicTemporaryQueue(SimpleString topicTemporaryQueue)
topicTemporaryQueue
- the topicTemporaryQueue to setpublic List<XAResource> getXAResources()
public void stop()
protected void setup() throws Exception
Exception
- Thrown if an error occursprotected void teardown()
protected ClientSession setupSession(ClientSessionFactory cf) throws Exception
cf
- Exception
- Thrown if an error occurspublic SimpleString getAddress()
public String toString()
public void startReconnectThread(String threadName)
public void reconnect(Throwable failure)
failure
- if reconnecting in the event of a failurepublic ActiveMQConnectionFactory getConnectionFactory()
Copyright © 2016 The Apache Software Foundation. All rights reserved.