public class ActiveMQXAConnection extends ActiveMQConnection implements javax.jms.XATopicConnection, javax.jms.XAQueueConnection, javax.jms.XAConnection
Connection
,
ConnectionFactory
,
QueueConnection
,
TopicConnection
,
TopicConnectionFactory
,
QueueConnection
,
QueueConnectionFactory
activeTempDestinations, alwaysSessionAsync, DEFAULT_BROKER_URL, DEFAULT_PASSWORD, DEFAULT_THREAD_POOL_SIZE, DEFAULT_USER, dispatchAsync, transportInterruptionProcessingComplete
Modifier | Constructor and Description |
---|---|
protected |
ActiveMQXAConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
Creates a
Session object. |
javax.jms.XAQueueSession |
createXAQueueSession() |
javax.jms.XASession |
createXASession() |
javax.jms.XATopicSession |
createXATopicSession() |
int |
getXaAckMode() |
void |
setXaAckMode(int xaAckMode) |
addConnectionConsumer, addDispatcher, addProducer, addSession, addTransportListener, asyncSendPacket, changeUserInfo, checkClientIDWasManuallySpecified, checkClosed, checkClosedOrFailed, cleanup, cleanUpTempDestinations, close, createBlobTransferPolicy, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createDurableConnectionConsumer, createQueueSession, createTempDestination, createTopicSession, deleteTempDestination, destroyDestination, doCleanup, ensureConnectionInfoSent, getBlobTransferPolicy, getBrokerInfo, getBrokerName, getClientID, getClientInternalExceptionListener, getCloseTimeout, getConnectionInfo, getConnectionStats, getConnectResponseTimeout, getConsumerFailoverRedeliveryWaitPeriod, getDestinationSource, getExceptionListener, getExecutor, getFirstFailureError, getInitializedClientID, getLocalTransactionIdGenerator, getMaxThreadPoolSize, getMetaData, getNextSessionId, getOptimizeAcknowledgeTimeOut, getOptimizedAckScheduledAckInterval, getPrefetchPolicy, getProducerWindowSize, getProtocolVersion, getRedeliveryPolicy, getRedeliveryPolicyMap, getRejectedTaskHandler, getResourceManagerId, getScheduler, getSendTimeout, getSessions, getSessionTaskRunner, getStats, getTimeCreated, getTransformer, getTransport, getTransportChannel, getTrustedPackages, getWarnAboutUnstartedConnectionTimeout, hasDispatcher, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isClosed, isClosing, isConsumerExpiryCheckEnabled, isCopyMessageOnSend, isDeleted, isDisableTimeStampsByDefault, isDispatchAsync, isDuplicate, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isNonBlockingRedelivery, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isRmIdFromConnectionId, isSendAcksAsync, isStarted, isStatsEnabled, isTransactedIndividualAck, isTransportFailed, isTrustAllPackages, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isUserSpecifiedClientID, isWatchTopicAdvisories, makeConnection, makeConnection, makeConnection, onAsyncException, onClientInternalException, onCommand, onConnectionControl, onConsumerControl, onException, onWireFormatInfo, removeConnectionConsumer, removeDispatcher, removeDispatcher, removeProducer, removeSession, removeTransportListener, rollbackDuplicate, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setCheckForDuplicates, setClientID, setClientInternalExceptionListener, setCloseTimeout, setConnectResponseTimeout, setConsumerExpiryCheckEnabled, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDefaultClientID, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMaxThreadPoolSize, setMessagePrioritySupported, setNestedMapAndListEnabled, setNonBlockingRedelivery, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedAckScheduledAckInterval, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setRedeliveryPolicyMap, setRejectedTaskHandler, setRmIdFromConnectionId, setSendAcksAsync, setSendTimeout, setSessionTaskRunner, setStatsEnabled, setTransactedIndividualAck, setTransformer, setTrustAllPackages, setTrustedPackages, setUseAsyncSend, setUseCompression, setUseDedicatedTaskRunner, setUseRetroactiveConsumer, setUserName, setWarnAboutUnstartedConnectionTimeout, setWatchTopicAdvisories, start, stop, syncSendPacket, syncSendPacket, syncSendPacket, toString, transportFailed, transportInterruptionProcessingComplete, transportInterupted, transportResumed, unsubscribe, waitForTransportInterruptionProcessingToComplete
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
protected ActiveMQXAConnection(Transport transport, IdGenerator clientIdGenerator, IdGenerator connectionIdGenerator, JMSStatsImpl factoryStats) throws Exception
Exception
public javax.jms.XASession createXASession() throws javax.jms.JMSException
createXASession
in interface javax.jms.XAConnection
javax.jms.JMSException
public javax.jms.XATopicSession createXATopicSession() throws javax.jms.JMSException
createXATopicSession
in interface javax.jms.XATopicConnection
javax.jms.JMSException
public javax.jms.XAQueueSession createXAQueueSession() throws javax.jms.JMSException
createXAQueueSession
in interface javax.jms.XAQueueConnection
javax.jms.JMSException
public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
ActiveMQConnection
Session
object.createSession
in interface javax.jms.Connection
createSession
in interface javax.jms.XAConnection
createSession
in class ActiveMQConnection
transacted
- indicates whether the session is transactedacknowledgeMode
- indicates whether the consumer or the client will
acknowledge any messages it receives; ignored if the
session is transacted. Legal values are
Session.AUTO_ACKNOWLEDGE
,
Session.CLIENT_ACKNOWLEDGE
, and
Session.DUPS_OK_ACKNOWLEDGE
.javax.jms.JMSException
- if the Connection
object fails to
create a session due to some internal error or lack of
support for the specific transaction and acknowledgement
mode.Session.AUTO_ACKNOWLEDGE
,
Session.CLIENT_ACKNOWLEDGE
,
Session.DUPS_OK_ACKNOWLEDGE
public void setXaAckMode(int xaAckMode)
public int getXaAckMode()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.