jrun.jms.asf
Class ServerSessionPoolImpl

jrun.jms.asf.ServerSessionPoolImpl

Direct Known Subclasses:

MDBServerSessionPoolImpl

public class ServerSessionPoolImpl

Field Summary

protected ASFService	m_asfManager
protected javax.jms.Connection	m_connection
protected Logger	m_logger
protected javax.jms.MessageListener	m_MessageListener
protected java.lang.String	m_MessageListenerClassName
protected int	m_mlSettingsType
protected ServerSessionPoolFactory	m_sspf

Constructor Summary

ServerSessionPoolImpl(ServerSessionPoolFactory sspf, javax.jms.Connection connection, ASFService manager, boolean transacted, int acknowlege)

ServerSessionPoolImpl(ServerSessionPoolFactory sspf, javax.jms.Connection connection, boolean transacted, int acknowlege, javax.jms.MessageListener ml)

ServerSessionPoolImpl(ServerSessionPoolFactory sspf, javax.jms.Connection connection, java.lang.String mlClassname, boolean transacted, int acknowlege)

Method Summary

protected ServerSessionImpl	createServerSession()
void	destroyServerSession(ServerSessionImpl ss)
int	get_maxSSPoolSize()
int	get_minSSPoolSize()
protected javax.jms.MessageListener	getMessageListener()
javax.jms.ServerSession	getServerSession()
protected void	initServerSessionPool()
void	returnServerSession(ServerSessionImpl ss)
protected void	runSession(ServerSessionImpl ss)
void	setLogger(Logger _lg)
void	stopPool()

Field Detail

m_logger

protected Logger m_logger

m_sspf

protected ServerSessionPoolFactory m_sspf

m_connection

protected javax.jms.Connection m_connection

m_MessageListenerClassName

protected java.lang.String m_MessageListenerClassName

m_MessageListener

protected javax.jms.MessageListener m_MessageListener

m_asfManager

protected ASFService m_asfManager

m_mlSettingsType

protected int m_mlSettingsType

Constructor Detail

ServerSessionPoolImpl

public ServerSessionPoolImpl(ServerSessionPoolFactory sspf,
                             javax.jms.Connection connection,
                             java.lang.String mlClassname,
                             boolean transacted,
                             int acknowlege)
                      throws javax.jms.JMSException

ServerSessionPoolImpl

public ServerSessionPoolImpl(ServerSessionPoolFactory sspf,
                             javax.jms.Connection connection,
                             ASFService manager,
                             boolean transacted,
                             int acknowlege)
                      throws javax.jms.JMSException

ServerSessionPoolImpl

public ServerSessionPoolImpl(ServerSessionPoolFactory sspf,
                             javax.jms.Connection connection,
                             boolean transacted,
                             int acknowlege,
                             javax.jms.MessageListener ml)
                      throws javax.jms.JMSException

Method Detail

setLogger

public void setLogger(Logger _lg)

get_minSSPoolSize

public int get_minSSPoolSize()

get_maxSSPoolSize

public int get_maxSSPoolSize()

initServerSessionPool

protected void initServerSessionPool()
                              throws javax.jms.JMSException

getServerSession

public javax.jms.ServerSession getServerSession()
                                         throws javax.jms.JMSException

destroyServerSession

public void destroyServerSession(ServerSessionImpl ss)

returnServerSession

public void returnServerSession(ServerSessionImpl ss)

stopPool

public void stopPool()

createServerSession

protected ServerSessionImpl createServerSession()
                                         throws javax.jms.JMSException

getMessageListener

protected javax.jms.MessageListener getMessageListener()
                                                throws javax.jms.JMSException

runSession

protected void runSession(ServerSessionImpl ss)
                   throws javax.jms.JMSException