public interface AdaptrisMessageProducer extends AdaptrisMessageWorker, AdaptrisMessageSender
Implementations of AdaptrisMessageProducer
produce messages to a destination (such as a JMS Queue or file system
directory).
AdaptrisMessageSender
CONFIRMATION_ID_KEY
Modifier and Type | Method and Description |
---|---|
ProduceDestination |
getDestination()
Returns the default
ProduceDestination for this instance. |
AdaptrisMessage |
request(AdaptrisMessage msg)
Produce the
AdaptrisMessage to the configured destination and blocks indefinitely for a reply. |
AdaptrisMessage |
request(AdaptrisMessage msg,
long timeout)
Produces the
AdaptrisMessage to the configured ProduceDestination and blocks for the specified timeout for a
reply. |
AdaptrisMessage |
request(AdaptrisMessage msg,
ProduceDestination destination)
Produces the
AdaptrisMessage to the passed supplied ProduceDestination and blocks indefinitely for a reply. |
AdaptrisMessage |
request(AdaptrisMessage msg,
ProduceDestination destination,
long timeoutMs)
Produces the
AdaptrisMessage to the passed supplied ProduceDestination and blocks for the specified timeout for
a reply. |
void |
setDestination(ProduceDestination destination)
Set the default
ProduceDestination . |
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
close, init, start, stop
prepare
createName, createQualifier, isTrackingEndpoint
produce, produce
AdaptrisMessage request(AdaptrisMessage msg) throws ProduceException
AdaptrisMessage
to the configured destination and blocks indefinitely for a reply.msg
- the AdaptrisMessage
to produceAdaptrisMessage
which is generally the same as supplied parameterProduceException
- wrapping any underlying ExceptionsAdaptrisMessage request(AdaptrisMessage msg, ProduceDestination destination) throws ProduceException
AdaptrisMessage
to the passed supplied ProduceDestination
and blocks indefinitely for a reply.msg
- the AdaptrisMessage
to producedestination
- the ProduceDestination
to produce toAdaptrisMessage
which is generally the same as supplied parameterProduceException
- wrapping any underlying ExceptionsAdaptrisMessage request(AdaptrisMessage msg, ProduceDestination destination, long timeoutMs) throws ProduceException
AdaptrisMessage
to the passed supplied ProduceDestination
and blocks for the specified timeout for
a reply.msg
- the AdaptrisMessage
to producedestination
- the ProduceDestination
to produce totimeoutMs
- the time to wait for a reply in millisecondsAdaptrisMessage
which is generally the same as supplied parameterProduceException
- wrapping any underlying ExceptionsAdaptrisMessage request(AdaptrisMessage msg, long timeout) throws ProduceException
AdaptrisMessage
to the configured ProduceDestination
and blocks for the specified timeout for a
reply.msg
- the AdaptrisMessage
to producetimeout
- the time to wait for a reply in millisecondsAdaptrisMessage
which is generally the same as supplied parameterProduceException
- wrapping any underlying ExceptionsProduceDestination getDestination()
ProduceDestination
for this instance.ProduceDestination
used in the absence of any other information.void setDestination(ProduceDestination destination)
ProduceDestination
.destination
- the ProduceDestination
to use