@ComponentProfile(summary="Default NO-OP producer implementation", tag="producer,base", recommended=NullConnection.class) public class NullMessageProducer extends AdaptrisMessageProducerImp
Null implementation of AdaptrisMessageProducer
.
In the adapter configuration file this class is aliased as null-message-producer which is the preferred alternative to the fully qualified classname when building your configuration.
log
Constructor and Description |
---|
NullMessageProducer() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
endpoint(AdaptrisMessage msg)
Return the endpoint that will be derived from the message.
|
ProduceDestination |
getDestination()
Deprecated.
|
void |
prepare()
Prepare for initialisation.
|
void |
produce(AdaptrisMessage msg)
Produces the
AdaptrisMessage to the default destination. |
void |
produce(AdaptrisMessage msg,
ProduceDestination destination)
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.
|
void |
setDestination(ProduceDestination destination)
Deprecated.
|
createName
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
createQualifier, isTrackingEndpoint
public 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 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 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 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 Exceptionspublic void prepare() throws CoreException
ComponentLifecycleExtension
CoreException
public java.lang.String endpoint(AdaptrisMessage msg) throws ProduceException
AdaptrisMessageProducerImp
The purpose of this method is to mitigate the number of changes that need to happen because
ProduceDestination
is being deprecated; boilerplate code can still be present in the
parent super-classes w/o impacting concrete sub-classes "too much".
endpoint
in class AdaptrisMessageProducerImp
ProduceException
AdaptrisMessageProducer.request(AdaptrisMessage, ProduceDestination)
,
AdaptrisMessageProducer.request(AdaptrisMessage, ProduceDestination, long)
,
AdaptrisMessageSender.produce(AdaptrisMessage)
,
AdaptrisMessageSender.produce(AdaptrisMessage, ProduceDestination)
public 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 void produce(AdaptrisMessage msg, ProduceDestination destination) throws ProduceException
AdaptrisMessageSender
AdaptrisMessage
to the supplied
ProduceDestination
, over-riding any configured destinations.msg
- the AdaptrisMessage
to producedestination
- the ProduceDestination
to produce toProduceException
- wrapping any underlying Exceptions@Deprecated public ProduceDestination getDestination()
@Deprecated public void setDestination(ProduceDestination destination)