org.gytheio.messaging.camel

Class CamelRequestReplyMessageProducer<RQ extends org.gytheio.messaging.Request<RP>,RP extends org.gytheio.messaging.Reply>

java.lang.Object

org.gytheio.messaging.camel.CamelMessageProducer

org.gytheio.messaging.camel.CamelRequestReplyMessageProducer<RQ,RP>

Type Parameters:

RQ - the request type

RP - the reply type

All Implemented Interfaces:

org.gytheio.messaging.MessageProducer, org.gytheio.messaging.RequestReplyMessageProducer<RQ,RP>

public class CamelRequestReplyMessageProducer<RQ extends org.gytheio.messaging.Request<RP>,RP extends org.gytheio.messaging.Reply>
extends CamelMessageProducer
implements org.gytheio.messaging.RequestReplyMessageProducer<RQ,RP>

An Apache Camel implementation of a request-reply message producer.

A pending requests map is maintained and the CamelRequestReplyMessageProducer.ReplyCallable periodically polls that map to determine if a correlated reply has been received.

Note that the built-in Camel asynchronous processing was not used for a few reasons:

• Routing of the temp queues back to the appropriate location and custom unmarshalling proved problematic
• Several references stated that there could be additional overhead in constructing the temp queues even with caching
• Clustering of pending requests would have likely been much more difficult

Author:

Ray Gauss II

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CamelRequestReplyMessageProducer.ReplyCallable Class which polls the pending requests map to determine if a correlated reply has been received.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	executorService
protected Map<String,RP>	pendingRequests
protected long	pollingIntervalMs
protected long	timeoutMs

Fields inherited from class org.gytheio.messaging.camel.CamelMessageProducer

endpoint, ERROR_SENDING, HEADER_JMS_AMQP_MESSAGE_FORMAT, HEADER_JMS_AMQP_MESSAGE_FORMAT_VALUE, producer

Constructor Summary

Constructors

Constructor and Description
CamelRequestReplyMessageProducer()

Method Summary

Methods

Modifier and Type	Method and Description
Future<RP>	asyncRequest(RQ request)
void	init()
void	onReceive(Object message)
void	setExecutorService(ExecutorService executorService) The executor service to be used for executing the polling callable
void	setPollingIntervalMs(long pollingIntervalMs) The pending request polling interval in milliseconds
void	setTimeoutMs(long timeoutMs) The pending request timeout in milliseconds

Methods inherited from class org.gytheio.messaging.camel.CamelMessageProducer

addHeaders, send, send, send, send, setEndpoint, setProducer, validateEndpoint

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.gytheio.messaging.MessageProducer

send, send, send, send

Field Detail

pendingRequests

protected Map<String,RP extends org.gytheio.messaging.Reply> pendingRequests

pollingIntervalMs

protected long pollingIntervalMs

timeoutMs

protected long timeoutMs

executorService

protected ExecutorService executorService

Constructor Detail

CamelRequestReplyMessageProducer

public CamelRequestReplyMessageProducer()

Method Detail

setPollingIntervalMs

public void setPollingIntervalMs(long pollingIntervalMs)

The pending request polling interval in milliseconds

Parameters:

pollingIntervalMs -

setTimeoutMs

public void setTimeoutMs(long timeoutMs)

The pending request timeout in milliseconds

Parameters:

timeoutMs -

setExecutorService

public void setExecutorService(ExecutorService executorService)

The executor service to be used for executing the polling callable

Parameters:

executorService -

init

public void init()

asyncRequest

public Future<RP> asyncRequest(RQ request)

Specified by:

asyncRequest in interface org.gytheio.messaging.RequestReplyMessageProducer<RQ extends org.gytheio.messaging.Request<RP>,RP extends org.gytheio.messaging.Reply>

onReceive

public void onReceive(Object message)