public class ServerSessionPoolImpl extends Object implements ServerSessionPool
Constructor and Description |
---|
ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker,
int maxSessions) |
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) |
public ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)
public ServerSession getServerSession() throws JMSException
getServerSession
in interface ServerSessionPool
JMSException
public void returnToPool(ServerSessionImpl ss)
public void removeFromPool(ServerSessionImpl ss)
public void close()
protected int closeSessions()
public boolean isClosing()
public void setClosing(boolean closing)
closing
- The closing to set.Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.