public class ActiveMQXAConnection extends ActiveMQConnection implements XATopicConnection, XAQueueConnection, XAConnection
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 |
---|---|
Session |
createSession(boolean transacted,
int acknowledgeMode)
Creates a
Session object. |
XAQueueSession |
createXAQueueSession() |
XASession |
createXASession() |
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, isWatchTopicAdvisories, makeConnection, makeConnection, makeConnection, onAsyncException, onClientInternalException, onCommand, onConnectionControl, onConsumerControl, onControlCommand, 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
createTopicSession
createConnectionConsumer, createDurableConnectionConsumer
createQueueSession
createConnectionConsumer
close, createConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
protected ActiveMQXAConnection(Transport transport, IdGenerator clientIdGenerator, IdGenerator connectionIdGenerator, JMSStatsImpl factoryStats) throws Exception
Exception
public XASession createXASession() throws JMSException
createXASession
in interface XAConnection
JMSException
public XATopicSession createXATopicSession() throws JMSException
createXATopicSession
in interface XATopicConnection
JMSException
public XAQueueSession createXAQueueSession() throws JMSException
createXAQueueSession
in interface XAQueueConnection
JMSException
public Session createSession(boolean transacted, int acknowledgeMode) throws JMSException
ActiveMQConnection
Session
object.createSession
in interface Connection
createSession
in interface 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
.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–2016 FuseSource, Corp.. All rights reserved.