com.sun.genericra.inbound
Class InboundJmsResource

java.lang.Object
  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.