public abstract class MsmqProducerBase extends ProduceOnlyProducerImp implements com.adaptris.core.licensing.LicensedComponent
AdaptrisMessageProducer
Request reply is not supported, an UnsupportedOperationException is thrown if an attempt is made to use request()
The AdaptrisConnection associated with this producer type should be a MsmqConnection
.
The string returned by the configured ProduceDestination should be a MSMQ Queue name in the form
DIRECT=OS:.\private$\zzlc
or similar.
Possible formats for the Destination are (see the MSMQQueueInfo.FormatName documentation)
Requires an Enterprise license
Note that this MSMQ implementation only supports MSMQ 3.0 and higher; This means Windows XP Professional, Windows Server 2003 and later operating systems.
Queue
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
MsmqProducerBase()
Default Constructor.
|
produce, request, request, request, request
getDestination, setDestination
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
createName, createQualifier, isTrackingEndpoint
public MsmqProducerBase()
public final void prepare() throws CoreException
prepare
in interface ComponentLifecycleExtension
CoreException
public boolean isEnabled(com.adaptris.core.licensing.License license)
isEnabled
in interface com.adaptris.core.licensing.LicensedComponent
public void init() throws CoreException
init
in interface ComponentLifecycle
CoreException
public void start() throws CoreException
start
in interface ComponentLifecycle
CoreException
public void stop()
stop
in interface ComponentLifecycle
public void close()
close
in interface ComponentLifecycle
public MQOAConstants.ShareMode getShareMode()
public void setShareMode(MQOAConstants.ShareMode s)
s
- the shareMode to setMQOAConstants.ShareMode
public java.util.List<PropertyMapper> getPropertyMappers()
public void setPropertyMappers(java.util.List<PropertyMapper> mappers)
mappers
- the mappers to setPropertyMapper
,
addPropertyMapper(PropertyMapper)
public void addPropertyMapper(PropertyMapper p)
p
- the property mapperpublic MQOAConstants.TransactionMode getTransactionMode()
public void setTransactionMode(MQOAConstants.TransactionMode s)
s
- the transactionMode to setMQOAConstants.TransactionMode
public QueueFactory retrieveQueueFactory()
public void registerQueueFactory(QueueFactory queueFactory)
public MessageFactory retrieveMsmqMessageFactory()
public void registerMsmqMessageFactory(MessageFactory messageFactory)
protected abstract void setMsmqMessageBody(AdaptrisMessage aMsg, Message msmqMsg) throws MSMQException
MSMQException
public void produce(AdaptrisMessage m, ProduceDestination d) throws ProduceException
produce
in interface AdaptrisMessageSender
ProduceException
AdaptrisMessageSender.produce(AdaptrisMessage, ProduceDestination)
Copyright Adaptris