Package com.adaptris.xa.jms

Class XAJmsProducerImpl

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.core.RequestReplyProducerBase

com.adaptris.core.jms.JmsProducerImpl

com.adaptris.core.jms.JmsProducer

com.adaptris.xa.jms.XAJmsProducerImpl

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, JmsActorConfig, LicensedComponent, MessageEventGenerator

Direct Known Subclasses:

XAJmsProducer

public abstract class XAJmsProducerImpl
extends JmsProducer
implements JmsActorConfig, LicensedComponent

Nested Class Summary

Nested classes/interfaces inherited from class com.adaptris.core.jms.JmsProducer

JmsProducer.MyJmsDestination

Field Summary

Fields

Modifier and Type	Field	Description
protected @NotNull @NonNull TransactionManager	transactionManager

Fields inherited from class com.adaptris.core.jms.JmsProducerImpl

refreshSessionIfProduceException

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
XAJmsProducerImpl()

Method Summary

Modifier and Type	Method	Description
int	configuredAcknowledgeMode()
javax.jms.Session	currentSession()
@NonNull TransactionManager	getTransactionManager()
@NonNull String	getXaResourceName()	Name to enlist a resource to the transaction manager.
boolean	isEnabled(License license)
void	prepare()
protected ProducerXASession	producerSession()
void	setTransactionManager(@NonNull TransactionManager transactionManager)
protected ProducerXASession	setupSession(AdaptrisMessage msg)
void	setXaResourceName(@NonNull String xaResourceName)	Name to enlist a resource to the transaction manager.

Methods inherited from class com.adaptris.core.jms.JmsProducer

buildDestination, createReplyTo, endpoint, getEndpoint, perMessageProperties, produce, produce, produce, request, request, setEndpoint, vendorImplementation, waitForReply, withEndpoint

Methods inherited from class com.adaptris.core.jms.JmsProducerImpl

acknowledge, calculateDeliveryMode, calculatePriority, calculateTimeToLive, captureOutgoingMessageDetails, captureOutgoingMessageDetails, close, commit, configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, currentLogger, defaultTimeout, getAcknowledgeMode, getCaptureOutgoingMessageDetails, getCorrelationIdSource, getDeliveryMode, getMessageTranslator, getPerMessageProperties, getPriority, getRefreshSessionIfProduceException, getSessionFactory, getTtl, init, isManagedTransaction, logLinkedException, messagePriority, request, retrieveObjectDestination, rollback, rollbackTimeout, setAcknowledgeMode, setCaptureOutgoingMessageDetails, setCorrelationIdSource, setDeliveryMode, setMessageTranslator, setPerMessageProperties, setPriority, setRefreshSessionIfProduceException, setSessionFactory, setTtl, setupSession, start, stop, timeToLive, transactedSession, translate

Methods inherited from class com.adaptris.core.RequestReplyProducerBase

copyReplyContents, getIgnoreReplyMetadata, mergeReply, setIgnoreReplyMetadata

Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp

createName

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.jms.JmsActorConfig

configuredCorrelationIdSource, configuredMessageListener, configuredMessageTranslator, currentLogger, isManagedTransaction, rollbackTimeout

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createQualifier, isTrackingEndpoint

Field Details

transactionManager

@NotNull
@NonNull
protected @NotNull @NonNull TransactionManager transactionManager

Constructor Details

XAJmsProducerImpl

public XAJmsProducerImpl()

Method Details

prepare

public void prepare()
             throws CoreException

Specified by:

prepare in interface ComponentLifecycleExtension

Overrides:

prepare in class JmsProducer

Throws:

CoreException

isEnabled

public boolean isEnabled(License license)

Specified by:

isEnabled in interface LicensedComponent

setupSession

protected ProducerXASession setupSession(AdaptrisMessage msg)
                                  throws javax.jms.JMSException

Overrides:

setupSession in class JmsProducerImpl

Throws:

javax.jms.JMSException

producerSession

protected ProducerXASession producerSession()

Overrides:

producerSession in class JmsProducerImpl

configuredAcknowledgeMode

public int configuredAcknowledgeMode()

Specified by:

configuredAcknowledgeMode in interface JmsActorConfig

Overrides:

configuredAcknowledgeMode in class JmsProducerImpl

currentSession

public javax.jms.Session currentSession()

Specified by:

currentSession in interface JmsActorConfig

Overrides:

currentSession in class JmsProducerImpl

getXaResourceName

@NonNull
public @NonNull String getXaResourceName()

Name to enlist a resource to the transaction manager. Must be globally unique. A UUID is used if left empty.

setXaResourceName

public void setXaResourceName(@NonNull
 @NonNull String xaResourceName)

Name to enlist a resource to the transaction manager. Must be globally unique. A UUID is used if left empty.

getTransactionManager

@NonNull
public @NonNull TransactionManager getTransactionManager()

setTransactionManager

public void setTransactionManager(@NonNull
 @NonNull TransactionManager transactionManager)