public class JmsQueueConnection extends JmsConnection implements AutoCloseable
Constructor and Description |
---|
JmsQueueConnection(String connectionId,
Provider provider,
IdGenerator clientIdGenerator) |
Modifier and Type | Method and Description |
---|---|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
String subscriptionName,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode) |
addConnectionListener, addSession, checkClosed, checkClosedOrFailed, checkConsumeFromTemporaryDestination, close, createConnectionConsumer, createConnectionConsumer, createQueueSession, createSession, createTemporaryQueue, createTemporaryTopic, deleteTemporaryDestination, getClientID, getCloseTimeout, getConfiguredURI, getConnectedURI, getConnectTimeout, getExceptionListener, getId, getMessageFactory, getMessageIDBuilder, getMetaData, getNextSessionId, getNextTransactionId, getPassword, getPrefetchPolicy, getQueuePrefix, getRedeliveryPolicy, getRequestTimeout, getSendTimeout, getSessionAcknowledgeMode, getTopicPrefix, getUsername, isClosed, isConnected, isExplicitClientID, isFailed, isForceAsyncAcks, isForceAsyncSend, isForceSyncSend, isLocalMessageExpiry, isLocalMessagePriority, isPopulateJMSXUserID, isReceiveLocalOnly, isReceiveNoWaitLocalOnly, isStarted, isTemporaryDestinationDeleted, isValidatePropertyNames, onAsyncException, onConnectionEstablished, onConnectionFailure, onConnectionInterrupted, onConnectionRecovered, onConnectionRecovery, onConnectionRestored, onException, onException, onInboundMessage, onProviderException, onResourceRemotelyClosed, providerFailed, removeConnectionListener, removeSession, setClientID, setCloseTimeout, setConnectTimeout, setExceptionListener, setForceAsyncAcks, setForceAsyncSend, setForceSyncSend, setLocalMessageExpiry, setLocalMessagePriority, setPopulateJMSXUserID, setPrefetchPolicy, setQueuePrefix, setReceiveLocalOnly, setReceiveNoWaitLocalOnly, setRedeliveryPolicy, setRequestTimeout, setSendTimeout, setTopicPrefix, setValidatePropertyNames, shutdown, shutdown, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public JmsQueueConnection(String connectionId, Provider provider, IdGenerator clientIdGenerator) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createTopicSession
in interface javax.jms.TopicConnection
createTopicSession
in class JmsConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, String subscriptionName, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createDurableConnectionConsumer
in interface javax.jms.Connection
createDurableConnectionConsumer
in interface javax.jms.TopicConnection
createDurableConnectionConsumer
in class JmsConnection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.TopicConnection
createConnectionConsumer
in class JmsConnection
javax.jms.JMSException
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.