java.lang.Object
com.presumo.jms.client.JmsConnection
com.presumo.jms.client.JmsQueueConnection
- All Implemented Interfaces:
- javax.jms.Connection, com.presumo.jms.router.ConnectionListener, javax.jms.QueueConnection
- public class JmsQueueConnection
- extends JmsConnection
- implements javax.jms.QueueConnection
| Methods inherited from class com.presumo.jms.client.JmsConnection |
close, connectionLost, finalize, getClientID, getExceptionListener, getMetaData, removeSession, setClientID, setExceptionListener, start, stop |
| Methods inherited from interface javax.jms.Connection |
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop |
logger
private static com.presumo.util.log.Logger logger
JmsQueueConnection
public JmsQueueConnection(com.presumo.jms.router.Router router)
JmsQueueConnection
public JmsQueueConnection(com.presumo.jms.router.Router router,
java.lang.String host,
int port)
throws javax.jms.JMSException
createQueueSession
public javax.jms.QueueSession createQueueSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
- Specified by:
createQueueSession in interface javax.jms.QueueConnection
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue topic,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
throws javax.jms.JMSException
- Not implemented.
- Specified by:
createConnectionConsumer in interface javax.jms.QueueConnection