com.sun.genericra.inbound
Class EndpointConsumer

java.lang.Object
  extended by 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)
           
 
Method Summary
 void closeConsumer()
           
 void consumeMessage(javax.jms.Message message, InboundJmsResource jmsResource)
           
 javax.jms.Connection getConnection()
           
 java.lang.Object getConnectionFactory()
           
 javax.resource.spi.endpoint.MessageEndpointFactory getMessageEndpointFactory()
           
 javax.resource.spi.ResourceAdapter getResourceAdapter()
           
 ActivationSpec getSpec()
           
 void initialize(boolean isTx)
           
 boolean isStopped()
           
 void restart()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

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
Method Detail

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)