org.hornetq.ra.inflow
public class HornetQActivation extends Object
Modifier and Type | Field and Description |
---|---|
static Method |
ONMESSAGE
The onMessage method
|
Constructor and Description |
---|
HornetQActivation(HornetQResourceAdapter ra,
javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
HornetQActivationSpec spec)
Constructor
|
Modifier and Type | Method and Description |
---|---|
HornetQActivationSpec |
getActivationSpec()
Get the activation spec
|
SimpleString |
getAddress() |
HornetQConnectionFactory |
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() |
void |
handleFailure(Throwable failure)
Handles any failure by trying to reconnect
|
boolean |
isDeliveryTransacted()
Get whether delivery is transacted
|
boolean |
isTopic()
Is the destination a topic
|
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 |
stop()
Stop the activation
|
protected void |
teardown()
Teardown the activation
|
String |
toString()
Get a string representation
|
public static final Method ONMESSAGE
public HornetQActivation(HornetQResourceAdapter ra, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, HornetQActivationSpec spec) throws javax.resource.ResourceException
ra
- The resource adapterendpointFactory
- The endpoint factoryspec
- The activation specjavax.resource.ResourceException
- Thrown if an error occurspublic HornetQActivationSpec 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 handleFailure(Throwable failure)
failure
- the reason for the failurepublic HornetQConnectionFactory getConnectionFactory()
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.