public abstract class RequestReplyProducerImp extends AdaptrisMessageProducerImp
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
RequestReplyProducerImp() |
Modifier and Type | Method and Description |
---|---|
protected abstract long |
defaultTimeout()
The default timeout for request messages when not supplied.
|
protected abstract AdaptrisMessage |
doRequest(AdaptrisMessage msg,
ProduceDestination dest,
long timeout)
Actually do the request.
|
java.lang.Boolean |
getIgnoreReplyMetadata() |
void |
produce(AdaptrisMessage msg)
Produces the
AdaptrisMessage to the default destination. |
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 timeout)
Produces the
AdaptrisMessage to the passed supplied ProduceDestination and blocks for the specified timeout for
a reply. |
void |
setIgnoreReplyMetadata(java.lang.Boolean b)
Specify whether to ignore metadata from the reply.
|
boolean |
shouldIgnoreReplyMetadata() |
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
close, init, start, stop
prepare
createName, createQualifier, isTrackingEndpoint
produce
public final void produce(AdaptrisMessage msg) throws ProduceException
AdaptrisMessageSender
AdaptrisMessage
to the default destination.msg
- the @link AdaptrisMessage} to produceProduceException
- wrapping any underlying Exceptions#produce(AdaptrisMessage)
public 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 ExceptionsAdaptrisMessageProducer.request(AdaptrisMessage)
public 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 ExceptionsAdaptrisMessageProducer.request(AdaptrisMessage, long)
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#request(AdaptrisMessage,ProduceDestination)
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 Exceptions#request(AdaptrisMessage,
ProduceDestination, long)
protected abstract long defaultTimeout()
protected abstract AdaptrisMessage doRequest(AdaptrisMessage msg, ProduceDestination dest, long timeout) throws ProduceException
ProduceException
#request(AdaptrisMessage,
ProduceDestination, long)
public java.lang.Boolean getIgnoreReplyMetadata()
public void setIgnoreReplyMetadata(java.lang.Boolean b)
b
- public boolean shouldIgnoreReplyMetadata()