Package com.adaptris.core
Class RequestReplyProducerBase
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageProducerImp
-
- com.adaptris.core.RequestReplyProducerBase
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
- Direct Known Subclasses:
JmsProducerImpl
,RequestReplyProducerImp
public abstract class RequestReplyProducerBase extends AdaptrisMessageProducerImp
Abstract Request Reply enabled producer that may be extended by concrete sub-classes.
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description RequestReplyProducerBase()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
copyReplyContents(AdaptrisMessage reply, AdaptrisMessage original)
protected abstract long
defaultTimeout()
The default timeout for request messages when not supplied.java.lang.Boolean
getIgnoreReplyMetadata()
protected AdaptrisMessage
mergeReply(AdaptrisMessage reply, AdaptrisMessage msg)
void
setIgnoreReplyMetadata(java.lang.Boolean ignoreReplyMetadata)
-
Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp
createName, endpoint
-
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageProducer
request, request
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageSender
produce
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
-
Methods inherited from interface com.adaptris.core.ComponentLifecycle
close, init, start, stop
-
Methods inherited from interface com.adaptris.core.ComponentLifecycleExtension
prepare
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
defaultTimeout
protected abstract long defaultTimeout()
The default timeout for request messages when not supplied.- Returns:
- the default timeout.
-
copyReplyContents
protected void copyReplyContents(AdaptrisMessage reply, AdaptrisMessage original) throws ProduceException
- Throws:
ProduceException
-
mergeReply
protected AdaptrisMessage mergeReply(AdaptrisMessage reply, AdaptrisMessage msg) throws ProduceException
- Throws:
ProduceException
-
getIgnoreReplyMetadata
public java.lang.Boolean getIgnoreReplyMetadata()
-
setIgnoreReplyMetadata
public void setIgnoreReplyMetadata(java.lang.Boolean ignoreReplyMetadata)
-
-