public abstract class RequestReplyProducerImp extends RequestReplyProducerBase
log
Constructor and Description |
---|
RequestReplyProducerImp() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
doProduce(AdaptrisMessage msg,
java.lang.String endpoint)
Actually do the produce.
|
protected abstract AdaptrisMessage |
doRequest(AdaptrisMessage msg,
java.lang.String endpoint,
long timeout)
Actually do the request.
|
void |
produce(AdaptrisMessage msg)
Produces the
AdaptrisMessage to the default destination. |
void |
produce(AdaptrisMessage msg,
ProduceDestination dest)
Deprecated.
|
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)
Deprecated.
|
AdaptrisMessage |
request(AdaptrisMessage msg,
ProduceDestination destination,
long timeout)
Deprecated.
|
copyReplyContents, defaultTimeout, getIgnoreReplyMetadata, mergeReply, setIgnoreReplyMetadata
createName, endpoint
createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
close, init, start, stop
prepare
createQualifier, isTrackingEndpoint
public final void produce(AdaptrisMessage msg) throws ProduceException
AdaptrisMessageSender
AdaptrisMessage
to the default destination.msg
- the @link AdaptrisMessage} to produceProduceException
- wrapping any underlying Exceptions@Deprecated @Removal(version="4.0.0") public final void produce(AdaptrisMessage msg, ProduceDestination dest) throws ProduceException
AdaptrisMessageSender
AdaptrisMessage
to the supplied
ProduceDestination
, over-riding any configured destinations.msg
- the AdaptrisMessage
to producedest
- the ProduceDestination
to produce toProduceException
- wrapping any underlying Exceptionspublic final AdaptrisMessage request(AdaptrisMessage msg) throws ProduceException
AdaptrisMessageProducer
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 Exceptionspublic final AdaptrisMessage request(AdaptrisMessage msg, long timeout) throws ProduceException
AdaptrisMessageProducer
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 Exceptions@Deprecated @Removal(version="4.0.0") public final AdaptrisMessage request(AdaptrisMessage msg, ProduceDestination destination) throws ProduceException
AdaptrisMessageProducer
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 Exceptions@Deprecated @Removal(version="4.0.0") public final AdaptrisMessage request(AdaptrisMessage msg, ProduceDestination destination, long timeout) throws ProduceException
AdaptrisMessageProducer
AdaptrisMessage
to the passed supplied
ProduceDestination
and blocks for the specified timeout for a reply.msg
- the AdaptrisMessage
to producedestination
- the ProduceDestination
to produce totimeout
- the time to wait for a reply in millisecondsAdaptrisMessage
which is generally the same as
supplied parameterProduceException
- wrapping any underlying Exceptionsprotected abstract AdaptrisMessage doRequest(AdaptrisMessage msg, java.lang.String endpoint, long timeout) throws ProduceException
ProduceException
protected abstract void doProduce(AdaptrisMessage msg, java.lang.String endpoint) throws ProduceException
ProduceException