public class NevadoQueueConnection extends NevadoConnection implements javax.jms.QueueConnection
_inUse, DEFAULT_MAX_POLL_WAIT_MS
Constructor and Description |
---|
NevadoQueueConnection(SQSConnector sqsConnector) |
Modifier and Type | Method and Description |
---|---|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
String s,
javax.jms.ServerSessionPool serverSessionPool,
int i) |
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
String s,
String s1,
javax.jms.ServerSessionPool serverSessionPool,
int i) |
NevadoQueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode) |
checkClosed, close, createConnectionConsumer, createSession, createTemporaryQueue, createTemporaryTopic, deleteQueue, deleteTemporaryQueue, deleteTemporaryTopic, deleteTopic, deleteUnusedTemporaryQueues, deleteUnusedTemporaryTopics, getClientID, getConnectionID, getDurableSubcriptionPrefixOveride, getExceptionListener, getMaxPollWaitMs, getMetaData, getSQSConnector, initializeSession, isClosed, isRunning, listAllTemporaryQueues, listAllTemporaryTopics, ownsTemporaryDestination, setClientID, setDurableSubcriptionPrefixOveride, setExceptionListener, setMaxPollWaitMs, setOverrideJMSDeliveryMode, setOverrideJMSPriority, setOverrideJMSTTL, setTemporaryQueueSuffix, setTemporaryTopicSuffix, start, stop, subscribe, unsubscribe
public NevadoQueueConnection(SQSConnector sqsConnector) throws javax.jms.JMSException
javax.jms.JMSException
public NevadoQueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createQueueSession
in interface javax.jms.QueueConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, String s, javax.jms.ServerSessionPool serverSessionPool, int i) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.QueueConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, String s, String s1, javax.jms.ServerSessionPool serverSessionPool, int i) throws javax.jms.JMSException
createDurableConnectionConsumer
in interface javax.jms.Connection
createDurableConnectionConsumer
in class NevadoConnection
javax.jms.JMSException
Copyright © 2014. All Rights Reserved.