com.sun.genericra.inbound
Class InboundJmsResourcePool

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

public class InboundJmsResourcePool
extends java.lang.Object
implements javax.jms.ServerSessionPool

ServerSesionPool implementation as per JMS 1.1 spec.

Author:
Binod P.G

Constructor Summary
InboundJmsResourcePool(EndpointConsumer consumer, boolean transacted)
           
 
Method Summary
 InboundJmsResource create()
           
 void destroy()
          Destroys the ServerSessionPool.
 javax.jms.Connection getConnection()
           
 javax.jms.Connection getConnectionForDMD()
           
 EndpointConsumer getConsumer()
           
 javax.jms.ServerSession getServerSession()
           
 void initialize()
           
 boolean isTransacted()
           
 void put(InboundJmsResource resource)
           
 void releaseAllResources()
           
 void releaseAllWaitingThreads()
           
 void resumeWaitingThread()
           
 void stop()
          Stops message delivery.
 void validate()
           
 void waitForAll()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InboundJmsResourcePool

public InboundJmsResourcePool(EndpointConsumer consumer,
                              boolean transacted)
Method Detail

initialize

public void initialize()
                throws javax.resource.ResourceException
Throws:
javax.resource.ResourceException

getConsumer

public EndpointConsumer getConsumer()

getConnection

public javax.jms.Connection getConnection()

getConnectionForDMD

public javax.jms.Connection getConnectionForDMD()

create

public InboundJmsResource create()
                          throws javax.jms.JMSException
Throws:
javax.jms.JMSException

getServerSession

public javax.jms.ServerSession getServerSession()
                                         throws javax.jms.JMSException
Specified by:
getServerSession in interface javax.jms.ServerSessionPool
Throws:
javax.jms.JMSException

validate

public void validate()
              throws javax.jms.JMSException
Throws:
javax.jms.JMSException

put

public void put(InboundJmsResource resource)

stop

public void stop()
          throws javax.jms.JMSException
Stops message delivery. Any message that is currently being delivered will not be affected. It can be resumed later.

Throws:
javax.jms.JMSException

destroy

public void destroy()
             throws javax.jms.JMSException
Destroys the ServerSessionPool.

Throws:
javax.jms.JMSException

waitForAll

public void waitForAll()

releaseAllWaitingThreads

public void releaseAllWaitingThreads()

releaseAllResources

public void releaseAllResources()

isTransacted

public boolean isTransacted()

resumeWaitingThread

public void resumeWaitingThread()