public class JmsActivation extends Object implements javax.jms.ExceptionListener
Modifier and Type | Field and Description |
---|---|
protected javax.jms.Connection |
connection
The connection
|
protected AtomicBoolean |
deliveryActive
Whether delivery is active
|
protected javax.jms.Destination |
destination
The destination
|
protected javax.resource.spi.endpoint.MessageEndpointFactory |
endpointFactory
The message endpoint factory
|
protected boolean |
isDeliveryTransacted
Is the delivery transacted
|
protected boolean |
isTopic
The destination type
|
static Method |
ONMESSAGE
The onMessage method
|
protected JmsServerSessionPool |
pool
The server session pool
|
protected JmsResourceAdapter |
ra
The resource adapter
|
protected JmsActivationSpec |
spec
The activation spec
|
protected TransactionManager |
tm
The TransactionManager
|
Constructor and Description |
---|
JmsActivation(JmsResourceAdapter ra,
javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
JmsActivationSpec spec) |
Modifier and Type | Method and Description |
---|---|
static Context |
convertStringToContext(String jndiParameters) |
static String |
defaultToString(Object object) |
JmsActivationSpec |
getActivationSpec() |
javax.jms.Connection |
getConnection() |
javax.jms.Destination |
getDestination() |
javax.resource.spi.endpoint.MessageEndpointFactory |
getMessageEndpointFactory() |
TransactionManager |
getTransactionManager() |
javax.resource.spi.work.WorkManager |
getWorkManager() |
void |
handleFailure(Throwable failure)
Handles any failure by trying to reconnect
|
boolean |
isDeliveryTransacted() |
boolean |
isTopic() |
void |
onException(javax.jms.JMSException exception) |
protected void |
setupDestination(Context ctx)
Setup the Destination
|
protected void |
setupSessionPool()
Setup the server session pool
|
void |
start()
Start the activation
|
void |
stop()
Stop the activation
|
protected void |
teardown()
Teardown the activation
|
protected void |
teardownConnection()
Teardown the connection
|
protected void |
teardownDestination()
Teardown the destination
|
protected void |
teardownSessionPool()
Teardown the server session pool
|
String |
toString() |
public static final Method ONMESSAGE
protected JmsResourceAdapter ra
protected JmsActivationSpec spec
protected javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
protected AtomicBoolean deliveryActive
protected javax.jms.Destination destination
protected boolean isTopic
protected javax.jms.Connection connection
protected JmsServerSessionPool pool
protected boolean isDeliveryTransacted
protected TransactionManager tm
public JmsActivation(JmsResourceAdapter ra, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, JmsActivationSpec spec) throws javax.resource.ResourceException
javax.resource.ResourceException
public JmsActivationSpec getActivationSpec()
public javax.resource.spi.endpoint.MessageEndpointFactory getMessageEndpointFactory()
public boolean isDeliveryTransacted()
public javax.resource.spi.work.WorkManager getWorkManager()
public TransactionManager getTransactionManager()
public javax.jms.Connection getConnection()
public javax.jms.Destination getDestination()
public boolean isTopic()
public void start() throws javax.resource.ResourceException
javax.resource.ResourceException
- for any errorpublic void stop()
public void handleFailure(Throwable failure)
failure
- the reason for the failurepublic void onException(javax.jms.JMSException exception)
onException
in interface javax.jms.ExceptionListener
public static Context convertStringToContext(String jndiParameters) throws NamingException
NamingException
protected void teardown()
protected void setupDestination(Context ctx) throws Exception
ctx
- the naming contextException
- for any errorprotected void teardownDestination()
protected void teardownConnection()
protected void setupSessionPool() throws Exception
Exception
- for any errorprotected void teardownSessionPool()
Copyright © 2017 JBoss by Red Hat. All rights reserved.