Apache Camel: Processor

Processor

The Processor interface is used to implement consumers of message exchanges or to implement a Message Translator

Once you have written a class which implements processor like this...

public class MyProcessor implements Processor {
  public void process(Exchange exchange) {
    // do something...
  }
}

You can then easily use this inside a route by declaring the bean in Spring, say via the XML (or registering it in JNDI if that is your Registry)

<bean id="myProcessor" class="com.acme.MyProcessor"/>

Then in Camel you can do

from("activemq:myQueue").to("myProcessor");

There is a base class called ProcessorEndpoint which supports the full Endpoint semantics given a Processor instance.

So you just need to create a Component class by deriving from DefaultComponent which returns instances of ProcessorEndpoint. For more details see Writing Components