public class XASessionImpl extends AMQSession_0_10 implements javax.jms.XASession, javax.jms.XATopicSession, javax.jms.XAQueueSession
AMQSession.Dispatchable
DAEMON_DISPATCHER_THREAD, DISPATCHER_SHUTDOWN_TIMEOUT_MS, DISPATCHER_SHUTDOWN_TIMEOUT_MS_DEFAULT, IMMEDIATE_PREFETCH, IMMEDIATE_PREFETCH_DEFAULT, STRICT_AMQP, STRICT_AMQP_DEFAULT, STRICT_AMQP_FATAL, STRICT_AMQP_FATAL_DEFAULT
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
NO_ACKNOWLEDGE, PRE_ACKNOWLEDGE
Constructor and Description |
---|
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
boolean transacted,
int ackMode,
int defaultPrefetchHigh,
int defaultPrefetchLow,
String name) |
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
int defaultPrefetchHigh,
int defaultPrefetchLow)
Create a JMS XASession
|
XASessionImpl(Connection qpidConnection,
AMQConnection con,
int channelId,
int ackMode,
int defaultPrefetchHigh,
int defaultPrefetchLow) |
Modifier and Type | Method and Description |
---|---|
protected void |
acknowledgeImpl() |
void |
commit()
Throws a
TransactionInProgressException , since it should
not be called for an XASession object. |
Session |
createSession()
Create a qpid session.
|
protected Session |
getQpidSession()
Access to the underlying Qpid Session
|
javax.jms.QueueSession |
getQueueSession()
Gets the topic session associated with this
XATopicSession . |
javax.jms.Session |
getSession()
Gets the session associated with this XASession.
|
javax.jms.TopicSession |
getTopicSession()
Gets the topic session associated with this
XATopicSession . |
XAResource |
getXAResource()
Returns an XA resource.
|
void |
rollback()
Throws a
TransactionInProgressException , since it should
not be called for an XASession object. |
acknowledgeMessage, addDeliveredMessage, closed, commitImpl, createMessageConsumer, createMessageProducer, declareQueue, doBind, exception, flushAcknowledgments, getCurrentException, getLastException, getMessageDelegateFactory, getQpidConnection, handleQueueNodeCreation, isBound, isExchangeExist, isFlowBlocked, isQueueBound, isQueueBound, isQueueBound, isQueueBound, isQueueExist, isQueueExist, message, opened, rejectMessage, releaseForRollback, requestQueueDepth, resolveAddressType, resumed, send0_10QueueDeclare, sendClose, sendConsume, sendCreateQueue, sendExchangeDeclare, sendExchangeDeclare, sendExchangeDeclare, sendExchangeDelete, sendQueueBind, sendQueueDelete, sendRecover, sendRollback, sendSuspendChannel, sendTxCompletionsIfNecessary, setCurrentException, setFlowControl, sync, tagLE, updateRollbackMark
acknowledge, addBindingKey, addUnacknowledgedMessage, bindQueue, bindQueue, checkNotClosed, checkTransacted, checkValidTopic, checkValidTopic, clearDispatchQueue, close, close, closed, confirmConsumerCancelled, createBrowser, createBrowser, createBrowserConsumer, createBytesMessage, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumer, createConsumerImpl, createDurableSubscriber, createDurableSubscriber, createListMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createProducer, createProducer, createPublisher, createQueue, createQueue, createQueue, createQueueReceiver, createQueueReceiver, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryQueue, createTemporaryQueueName, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, declareAndBind, declareAndBind, declareExchange, declareQueue, declareQueue, deleteExchange, deleteQueue, deleteTemporaryDestination, dispatch, drainDispatchQueueWithDispatcher, getAcknowledgeMode, getAMQConnection, getChannelId, getConsumers, getDefaultPrefetch, getDefaultPrefetchHigh, getDefaultPrefetchLow, getDefaultQueueExchangeName, getDefaultTopicExchangeName, getDeliveredMessageTags, getDispatcher, getDispatcherThread, getFailoverMutex, getHighestDeliveryTag, getMessageEncryptionHelper, getMessageFactoryRegistry, getMessageListener, getPrefetch, getPrefetchedMessageTags, getQueueDepth, getQueueDepth, getTemporaryQueueExchangeName, getTemporaryTopicExchangeName, getTicket, getTransacted, getUnacknowledgedMessageTags, hasConsumer, hasFailedOverDirty, hasMessageListeners, isClosed, isClosing, isDeclareExchanges, isImmediatePrefetch, isStrictAMQP, isSuspended, isTransacted, markClean, markDirty, messageReceived, prefetch, preprocessAddressTopic, recover, rejectMessage, rejectMessage, resolveAddress, run, setLegacyFieldsForQueueType, setLegacyFieldsForTopicType, setMessageListener, setTicket, setUsingDispatcherForCleanup, stopDispatcherThread, stopExistingDispatcher, suspendChannel, suspendChannelIfNotClosing, unsubscribe, verifySubject
setClosed, setClosing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener, unsubscribe
public XASessionImpl(Connection qpidConnection, AMQConnection con, int channelId, int defaultPrefetchHigh, int defaultPrefetchLow)
public XASessionImpl(Connection qpidConnection, AMQConnection con, int channelId, int ackMode, int defaultPrefetchHigh, int defaultPrefetchLow)
public XASessionImpl(Connection qpidConnection, AMQConnection con, int channelId, boolean transacted, int ackMode, int defaultPrefetchHigh, int defaultPrefetchLow, String name)
public Session createSession()
createSession
in class AMQSession_0_10
public javax.jms.Session getSession() throws javax.jms.JMSException
getSession
in interface javax.jms.XASession
javax.jms.JMSException
- if an internal error occurs.public XAResource getXAResource()
getXAResource
in interface javax.jms.XASession
public void commit() throws javax.jms.JMSException
TransactionInProgressException
, since it should
not be called for an XASession object.commit
in interface javax.jms.Session
commit
in interface javax.jms.XASession
commit
in class AMQSession<BasicMessageConsumer_0_10,BasicMessageProducer_0_10>
javax.jms.TransactionInProgressException
- always.javax.jms.JMSException
- If the JMS provider fails to commit the transaction due to some internal error. This does
not mean that the commit is known to have failed, merely that it is not known whether it
failed or not.public void rollback() throws javax.jms.JMSException
TransactionInProgressException
, since it should
not be called for an XASession object.rollback
in interface javax.jms.Session
rollback
in interface javax.jms.XASession
rollback
in class AMQSession<BasicMessageConsumer_0_10,BasicMessageProducer_0_10>
javax.jms.TransactionInProgressException
- always.javax.jms.JMSException
- If the JMS provider fails to rollback the transaction due to some internal error. This does
not mean that the rollback is known to have failed, merely that it is not known whether it
failed or not.
TODO Be aware of possible changes to parameter order as versions change.protected Session getQpidSession()
getQpidSession
in class AMQSession_0_10
public javax.jms.QueueSession getQueueSession() throws javax.jms.JMSException
XATopicSession
.getQueueSession
in interface javax.jms.XAQueueSession
javax.jms.JMSException
- If an internal error occurs.public javax.jms.TopicSession getTopicSession() throws javax.jms.JMSException
XATopicSession
.getTopicSession
in interface javax.jms.XATopicSession
javax.jms.JMSException
- If an internal error occurs.protected void acknowledgeImpl()
acknowledgeImpl
in class AMQSession_0_10
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.