Package org.apache.activemq.ra
Class ServerSessionPoolImpl
- java.lang.Object
-
- org.apache.activemq.ra.ServerSessionPoolImpl
-
- All Implemented Interfaces:
ServerSessionPool
public class ServerSessionPoolImpl extends Object implements ServerSessionPool
$Date$
-
-
Constructor Summary
Constructors Constructor Description ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected int
closeSessions()
ServerSession
getServerSession()
boolean
isClosing()
void
removeFromPool(ServerSessionImpl ss)
void
returnToPool(ServerSessionImpl ss)
void
setClosing(boolean closing)
-
-
-
Constructor Detail
-
ServerSessionPoolImpl
public ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)
-
-
Method Detail
-
getServerSession
public ServerSession getServerSession() throws JMSException
- Specified by:
getServerSession
in interfaceServerSessionPool
- Throws:
JMSException
-
returnToPool
public void returnToPool(ServerSessionImpl ss)
-
removeFromPool
public void removeFromPool(ServerSessionImpl ss)
-
close
public void close()
-
closeSessions
protected int closeSessions()
-
isClosing
public boolean isClosing()
- Returns:
- Returns the closing.
-
setClosing
public void setClosing(boolean closing)
- Parameters:
closing
- The closing to set.
-
-