public class JmsTopicConnection extends JmsConnection implements AutoCloseable
Constructor and Description |
---|
JmsTopicConnection(String connectionId,
Provider provider,
IdGenerator clientIdGenerator) |
Modifier and Type | Method and Description |
---|---|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode) |
addConnectionListener, addSession, checkClosed, checkClosedOrFailed, checkConsumeFromTemporaryDestination, close, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createSession, createTemporaryQueue, createTemporaryTopic, createTopicSession, 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 JmsTopicConnection(String connectionId, Provider provider, IdGenerator clientIdGenerator) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.QueueConnection
createConnectionConsumer
in class JmsConnection
javax.jms.JMSException
public javax.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createQueueSession
in interface javax.jms.QueueConnection
createQueueSession
in class JmsConnection
javax.jms.JMSException
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.