|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.resource.adapter.jms.inflow.JmsActivation
A generic jms Activation.
Field Summary | |
protected org.jboss.jms.jndi.JMSProviderAdapter |
adapter
The jms provider adapter |
protected javax.jms.Connection |
connection
The connection |
protected EDU.oswego.cs.dl.util.concurrent.SynchronizedBoolean |
deliveryActive
Whether delivery is active |
protected javax.jms.Destination |
destination
The destination |
protected DLQHandler |
dlqHandler
The DLQ handler |
protected javax.resource.spi.endpoint.MessageEndpointFactory |
endpointFactory
The message endpoint factory |
protected boolean |
isDeliveryTransacted
Is the delivery transacted |
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 |
Constructor Summary | |
JmsActivation(JmsResourceAdapter ra,
javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
JmsActivationSpec spec)
|
Method Summary | |
JmsActivationSpec |
getActivationSpec()
|
javax.jms.Connection |
getConnection()
|
javax.jms.Destination |
getDestination()
|
DLQHandler |
getDLQHandler()
|
javax.resource.spi.endpoint.MessageEndpointFactory |
getMessageEndpointFactory()
|
org.jboss.jms.jndi.JMSProviderAdapter |
getProviderAdapter()
|
javax.resource.spi.work.WorkManager |
getWorkManager()
|
void |
handleFailure(Throwable failure)
Handles any failure by trying to reconnect |
boolean |
isDeliveryTransacted()
|
void |
onException(javax.jms.JMSException exception)
|
protected void |
setup()
Setup the activation |
protected void |
setupConnection(Context ctx)
Setup the Connection |
protected void |
setupDestination(Context ctx)
Setup the Destination |
protected void |
setupDLQ(Context ctx)
Setup the DLQ |
protected void |
setupJMSProviderAdapter()
Get the jms provider |
protected javax.jms.QueueConnection |
setupQueueConnection(Context ctx,
String user,
String pass,
String clientID)
Setup a Queue Connection |
protected void |
setupSessionPool()
Setup the server session pool |
protected javax.jms.TopicConnection |
setupTopicConnection(Context ctx,
String user,
String pass,
String clientID)
Setup a Topic Connection |
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 |
teardownDLQ()
Teardown the DLQ |
protected void |
teardownSessionPool()
Teardown the server session pool |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final Method ONMESSAGE
protected JmsResourceAdapter ra
protected JmsActivationSpec spec
protected javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
protected EDU.oswego.cs.dl.util.concurrent.SynchronizedBoolean deliveryActive
protected org.jboss.jms.jndi.JMSProviderAdapter adapter
protected javax.jms.Destination destination
protected javax.jms.Connection connection
protected JmsServerSessionPool pool
protected boolean isDeliveryTransacted
protected DLQHandler dlqHandler
Constructor Detail |
public JmsActivation(JmsResourceAdapter ra, javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, JmsActivationSpec spec) throws javax.resource.ResourceException
Method Detail |
public JmsActivationSpec getActivationSpec()
public javax.resource.spi.endpoint.MessageEndpointFactory getMessageEndpointFactory()
public boolean isDeliveryTransacted()
public javax.resource.spi.work.WorkManager getWorkManager()
public javax.jms.Connection getConnection()
public javax.jms.Destination getDestination()
public org.jboss.jms.jndi.JMSProviderAdapter getProviderAdapter()
public DLQHandler getDLQHandler()
public void start() throws javax.resource.ResourceException
javax.resource.ResourceException
- for any errorpublic void stop()
public void handleFailure(Throwable failure)
public void onException(javax.jms.JMSException exception)
onException
in interface javax.jms.ExceptionListener
protected void setup() throws Exception
Exception
- for any errorprotected void teardown()
protected void setupJMSProviderAdapter() throws Exception
Exception
protected void setupDLQ(Context ctx) throws Exception
ctx
- the naming context
Exception
- for any errorprotected void teardownDLQ()
protected void setupDestination(Context ctx) throws Exception
ctx
- the naming context
Exception
- for any errorprotected void teardownDestination()
protected void setupConnection(Context ctx) throws Exception
ctx
- the naming context
Exception
- for any errorprotected javax.jms.QueueConnection setupQueueConnection(Context ctx, String user, String pass, String clientID) throws Exception
ctx
- the naming contextuser
- the userpass
- the passwordclientID
- the client id
Exception
- for any errorprotected javax.jms.TopicConnection setupTopicConnection(Context ctx, String user, String pass, String clientID) throws Exception
ctx
- the naming contextuser
- the userpass
- the passwordclientID
- the client id
Exception
- for any errorprotected void teardownConnection()
protected void setupSessionPool() throws Exception
Exception
- for any errorprotected void teardownSessionPool()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |