com.sun.genericra.inbound
Class InboundJmsResourcePool
java.lang.Object
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
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
InboundJmsResourcePool
public InboundJmsResourcePool(EndpointConsumer consumer,
boolean transacted)
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()