public class ServerSessionPoolImpl extends Object implements javax.jms.ServerSessionPool
Constructor and Description |
---|
ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker,
int maxSessions) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected int |
closeSessions() |
javax.jms.ServerSession |
getServerSession() |
boolean |
isClosing() |
void |
removeFromPool(ServerSessionImpl ss) |
void |
returnToPool(ServerSessionImpl ss) |
void |
setClosing(boolean closing) |
public ServerSessionPoolImpl(ActiveMQEndpointWorker activeMQAsfEndpointWorker, int maxSessions)
public javax.jms.ServerSession getServerSession() throws javax.jms.JMSException
getServerSession
in interface javax.jms.ServerSessionPool
javax.jms.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–2019 The Apache Software Foundation. All rights reserved.