You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 5 Next »

Processor

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

Using a processor in a route

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("mProcessor");

Turning your processor into a full Component

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

See Also

  • No labels