org.apache.camel.component.spring.integration.adapter

Class CamelTargetAdapter

java.lang.Object

org.apache.camel.component.spring.integration.adapter.AbstractCamelAdapter

org.apache.camel.component.spring.integration.adapter.CamelTargetAdapter

All Implemented Interfaces:

org.springframework.integration.core.MessageHandler

public class CamelTargetAdapter
extends AbstractCamelAdapter
implements org.springframework.integration.core.MessageHandler

CamelTargetAdapter will redirect the Spring Integration message to the Camel context. When we inject the camel context into it, we need also specify the Camel endpoint url we will route the Spring Integration message to the Camel context

Version:

Constructor Summary

Constructors

Constructor and Description
CamelTargetAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.camel.ProducerTemplate	getCamelTemplate()
org.springframework.integration.MessageChannel	getReplyChannel()
void	handleMessage(org.springframework.integration.Message<?> message)
boolean	send(org.springframework.integration.Message<?> message)
void	setReplyChannel(org.springframework.integration.MessageChannel channel)

Methods inherited from class org.apache.camel.component.spring.integration.adapter.AbstractCamelAdapter

getCamelContext, getCamelEndpointUri, isExpectReply, setCamelContext, setCamelEndpointUri, setExpectReply

Methods inherited from class java.lang.Object

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

Constructor Detail

CamelTargetAdapter

public CamelTargetAdapter()

Method Detail

setReplyChannel

public void setReplyChannel(org.springframework.integration.MessageChannel channel)

getReplyChannel

public org.springframework.integration.MessageChannel getReplyChannel()

getCamelTemplate

public org.apache.camel.ProducerTemplate getCamelTemplate()
                                                   throws Exception

Throws:

Exception

send

public boolean send(org.springframework.integration.Message<?> message)
             throws Exception

Throws:

Exception

handleMessage

public void handleMessage(org.springframework.integration.Message<?> message)
                   throws org.springframework.integration.MessageDeliveryException

Specified by:

handleMessage in interface org.springframework.integration.core.MessageHandler

Throws:

org.springframework.integration.MessageDeliveryException