com.sun.genericra.inbound
Class InboundJmsResource

java.lang.Object
  extended by com.sun.genericra.inbound.InboundJmsResource
All Implemented Interfaces:
javax.jms.ServerSession

public class InboundJmsResource
extends java.lang.Object
implements javax.jms.ServerSession

ServerSession implementation as per JMS 1.1 specification. This serves as a placeholder for a MessageEndpoint obtained from application server.

Author:
Binod P.G

Constructor Summary
InboundJmsResource(javax.jms.Session session, InboundJmsResourcePool pool)
           
InboundJmsResource(javax.jms.Session session, InboundJmsResourcePool pool, javax.transaction.xa.XAResource xaresource)
           
 
Method Summary
 void destroy()
           
 DeliveryHelper getDeliveryHelper()
           
 javax.resource.spi.endpoint.MessageEndpoint getEndpoint()
           
 InboundJmsResourcePool getPool()
           
 javax.jms.Session getSession()
           
 javax.transaction.xa.XAResource getXAResource()
           
 javax.jms.XASession getXASession()
           
 boolean isFree()
           
 InboundJmsResource markAsBusy()
           
 InboundJmsResource markAsFree()
           
 void refresh()
          Creates the MessageEndpoint and start the delivery.
 InboundJmsResource refreshListener()
          Each time a serversession is checked out from the pool, the listener will be recreated.
 void release()
           
 void releaseEndpoint()
          Completes the Message delivery and release the MessageEndpoint.
 void start()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InboundJmsResource

public InboundJmsResource(javax.jms.Session session,
                          InboundJmsResourcePool pool)
                   throws javax.jms.JMSException
Throws:
javax.jms.JMSException

InboundJmsResource

public InboundJmsResource(javax.jms.Session session,
                          InboundJmsResourcePool pool,
                          javax.transaction.xa.XAResource xaresource)
                   throws javax.jms.JMSException
Throws:
javax.jms.JMSException
Method Detail

start

public void start()
           throws javax.jms.JMSException
Specified by:
start in interface javax.jms.ServerSession
Throws:
javax.jms.JMSException

refreshListener

public InboundJmsResource refreshListener()
                                   throws javax.jms.JMSException
Each time a serversession is checked out from the pool, the listener will be recreated.

Throws:
javax.jms.JMSException

destroy

public void destroy()

isFree

public boolean isFree()

markAsBusy

public InboundJmsResource markAsBusy()

markAsFree

public InboundJmsResource markAsFree()

getDeliveryHelper

public DeliveryHelper getDeliveryHelper()

getXAResource

public javax.transaction.xa.XAResource getXAResource()

getSession

public javax.jms.Session getSession()
Specified by:
getSession in interface javax.jms.ServerSession

getPool

public InboundJmsResourcePool getPool()

getXASession

public javax.jms.XASession getXASession()

getEndpoint

public javax.resource.spi.endpoint.MessageEndpoint getEndpoint()

release

public void release()

refresh

public void refresh()
             throws javax.jms.JMSException
Creates the MessageEndpoint and start the delivery.

Throws:
javax.jms.JMSException

releaseEndpoint

public void releaseEndpoint()
Completes the Message delivery and release the MessageEndpoint.