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 and Description
ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected int	closeSessions()
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()

closeSessions

protected int closeSessions()

isClosing

public boolean isClosing()

Returns:

Returns the closing.

setClosing

public void setClosing(boolean closing)

Parameters:

closing - The closing to set.