org.apache.activemq.ra
Class ServerSessionPoolImpl

java.lang.Object
  extended by org.apache.activemq.ra.ServerSessionPoolImpl
All Implemented Interfaces:
ServerSessionPool

public class ServerSessionPoolImpl
extends Object
implements ServerSessionPool

$Date: 2013-10-21 18:53:28 +0000 (Mon, 21 Oct 2013) $


Constructor Summary
ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)
           
 
Method Summary
 void close()
           
protected  int closeIdleSessions()
           
 ServerSession getServerSession()
           
 boolean isClosing()
           
 void removeFromPool(ServerSessionImpl ss)
           
 void returnToPool(ServerSessionImpl ss)
           
 void setClosing(boolean closing)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ServerSessionPoolImpl

public ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker,
                             int maxSessions)
Method Detail

getServerSession

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

returnToPool

public void returnToPool(ServerSessionImpl ss)

removeFromPool

public void removeFromPool(ServerSessionImpl ss)

close

public void close()

closeIdleSessions

protected int closeIdleSessions()

isClosing

public boolean isClosing()
Returns:
Returns the closing.

setClosing

public void setClosing(boolean closing)
Parameters:
closing - The closing to set.


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.