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 and Description
RequestReplyProducerBase()

Method Summary

Modifier and Type	Method and 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.AdaptrisMessageProducer

request, request, request, request

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

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

Methods inherited from interface com.adaptris.core.AdaptrisMessageSender

produce, produce

Constructor Detail

RequestReplyProducerBase

public RequestReplyProducerBase()

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)