Package org.apache.activemq.ra

Class ServerSessionPoolImpl

java.lang.Object
org.apache.activemq.ra.ServerSessionPoolImpl
All Implemented Interfaces:
jakarta.jms.ServerSessionPool
public class ServerSessionPoolImpl extends Object implements jakarta.jms.ServerSessionPool
$Date$

  • Constructor Details

    • ServerSessionPoolImpl

      public ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)

  • Method Details

    • getServerSession

      public jakarta.jms.ServerSession getServerSession() throws jakarta.jms.JMSException
      Specified by:
      getServerSession in interface jakarta.jms.ServerSessionPool
      Throws:
      jakarta.jms.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.