com.sun.genericra.inbound
Class EndpointConsumer
java.lang.Object
com.sun.genericra.inbound.EndpointConsumer
public class EndpointConsumer
- extends java.lang.Object
One EndpointConsumer
represents one MDB deployment.
Important assumptions:
- Each EndpointCOnsumer holds one InboundJmsResourcePool
(ServerSessionPool) which holds a javax.jms.Connection object.
- EndpointConsumer is also created when ra.getXAResources() is
is called for transaction recovery.
- Author:
- Binod P.G
Constructor Summary |
EndpointConsumer(javax.resource.spi.ActivationSpec actspec)
|
EndpointConsumer(javax.resource.spi.endpoint.MessageEndpointFactory mef,
javax.resource.spi.ActivationSpec actspec)
|
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EndpointConsumer
public EndpointConsumer(javax.resource.spi.endpoint.MessageEndpointFactory mef,
javax.resource.spi.ActivationSpec actspec)
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
EndpointConsumer
public EndpointConsumer(javax.resource.spi.ActivationSpec actspec)
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
getConnectionFactory
public java.lang.Object getConnectionFactory()
getMessageEndpointFactory
public javax.resource.spi.endpoint.MessageEndpointFactory getMessageEndpointFactory()
getSpec
public ActivationSpec getSpec()
getResourceAdapter
public javax.resource.spi.ResourceAdapter getResourceAdapter()
isStopped
public boolean isStopped()
getConnection
public javax.jms.Connection getConnection()
restart
public void restart()
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
start
public void start()
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
initialize
public void initialize(boolean isTx)
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
stop
public void stop()
closeConsumer
public void closeConsumer()
consumeMessage
public void consumeMessage(javax.jms.Message message,
InboundJmsResource jmsResource)