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 voidclose()protected intcloseSessions()ServerSessiongetServerSession()booleanisClosing()voidremoveFromPool(ServerSessionImpl ss)voidreturnToPool(ServerSessionImpl ss)voidsetClosing(boolean closing)
-
-
-
Constructor Detail
-
ServerSessionPoolImpl
public ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)
-
-
Method Detail
-
getServerSession
public ServerSession getServerSession() throws JMSException
- Specified by:
getServerSessionin 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.
-
-