public class DefaultServerSessionPool
extends java.lang.Object
implements javax.jms.ServerSessionPool
DefaultServerSessionPool
is a default implementation of
the JMS ServerSessionPool interface.
Modifier and Type | Field and Description |
---|---|
private java.util.LinkedList |
list
the list of ServerSession objects
|
private javax.jms.MessageListener |
listener
The MessageListener which are fired by new JMS Sessions
|
private SessionFactory |
sessionFactory
the factory used to create new Sessions
|
private long |
timeout
maximum blocking time, just in case a notify goes walkies
|
Constructor and Description |
---|
DefaultServerSessionPool() |
DefaultServerSessionPool(SessionFactory sessionFactory,
javax.jms.MessageListener listener,
int numberOfServerSessions) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.ServerSession |
createServerSession() |
javax.jms.ServerSession |
getServerSession()
Return a server session from the pool.
|
void |
putServerSession(javax.jms.ServerSession serverSession) |
private java.util.LinkedList list
private SessionFactory sessionFactory
private javax.jms.MessageListener listener
private long timeout
public DefaultServerSessionPool()
public DefaultServerSessionPool(SessionFactory sessionFactory, javax.jms.MessageListener listener, int numberOfServerSessions) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ServerSession getServerSession() throws javax.jms.JMSException
getServerSession
in interface javax.jms.ServerSessionPool
javax.jms.JMSException
- if a JMS error occurs.public void putServerSession(javax.jms.ServerSession serverSession)
protected javax.jms.ServerSession createServerSession() throws javax.jms.JMSException
javax.jms.JMSException