org.gytheio.messaging.camel

Class CamelMessageProducer

java.lang.Object

org.gytheio.messaging.camel.CamelMessageProducer

All Implemented Interfaces:

org.gytheio.messaging.MessageProducer

Direct Known Subclasses:

CamelRequestReplyMessageProducer

public class CamelMessageProducer
extends Object
implements org.gytheio.messaging.MessageProducer

An Apache Camel implementation of a message producer

Author:

Ray Gauss II

Field Summary

Fields

Modifier and Type	Field and Description
protected String	endpoint
protected static String	ERROR_SENDING
protected static String	HEADER_JMS_AMQP_MESSAGE_FORMAT
protected static Long	HEADER_JMS_AMQP_MESSAGE_FORMAT_VALUE
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected org.apache.camel.ProducerTemplate	producer

Constructor Summary

Constructors

Constructor and Description
CamelMessageProducer()

Method Summary

Methods

Modifier and Type	Method and Description
protected Map<String,Object>	addHeaders(Map<String,Object> origHeaders)
void	send(Object message)
void	send(Object message, Map<String,Object> headers)
void	send(Object message, String queueName)
void	send(Object message, String queueName, Map<String,Object> headers)
void	setEndpoint(String endpoint) The Camel endpoint for initial delivery of the messages into the Camel context which can then be routed as needed
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper) Optional object mapper to be used programatically in send(Object, String) or send(Object, String, Map) methods when an alternate endpoint is specified.
void	setProducer(org.apache.camel.ProducerTemplate producer) The Camel producer template
protected void	validateEndpoint(String endpoint) Checks that the given endpoint is valid

Methods inherited from class java.lang.Object

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

Field Detail

HEADER_JMS_AMQP_MESSAGE_FORMAT

protected static final String HEADER_JMS_AMQP_MESSAGE_FORMAT

See Also:

Constant Field Values

HEADER_JMS_AMQP_MESSAGE_FORMAT_VALUE

protected static final Long HEADER_JMS_AMQP_MESSAGE_FORMAT_VALUE

ERROR_SENDING

protected static final String ERROR_SENDING

See Also:

Constant Field Values

producer

protected org.apache.camel.ProducerTemplate producer

endpoint

protected String endpoint

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Detail

CamelMessageProducer

public CamelMessageProducer()

Method Detail

setProducer

public void setProducer(org.apache.camel.ProducerTemplate producer)

The Camel producer template

Parameters:

producer -

setEndpoint

public void setEndpoint(String endpoint)

The Camel endpoint for initial delivery of the messages into the Camel context which can then be routed as needed

Parameters:

endpoint -

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Optional object mapper to be used programatically in send(Object, String) or send(Object, String, Map) methods when an alternate endpoint is specified.

Parameters:

objectMapper -

validateEndpoint

protected void validateEndpoint(String endpoint)

Checks that the given endpoint is valid

Parameters:

endpoint -

addHeaders

protected Map<String,Object> addHeaders(Map<String,Object> origHeaders)

send

public void send(Object message)

Specified by:

send in interface org.gytheio.messaging.MessageProducer

send

public void send(Object message,
        Map<String,Object> headers)

Specified by:

send in interface org.gytheio.messaging.MessageProducer

send

public void send(Object message,
        String queueName)

Specified by:

send in interface org.gytheio.messaging.MessageProducer

send

public void send(Object message,
        String queueName,
        Map<String,Object> headers)

Specified by:

send in interface org.gytheio.messaging.MessageProducer