1 package de.campussource.cse;
2
3 import org.apache.camel.ProducerTemplate;
4 import org.apache.camel.EndpointInject;
5 import org.apache.camel.MessageDriven;
6 import org.apache.camel.Body;
7
8 public class ContentEnricher {
9
10 @EndpointInject(uri="activemq:BeforeSplitting")
11 ProducerTemplate producer;
12
13 @MessageDriven(uri="activemq:LSFTransformedOutput")
14 public void transformForSplitting(@Body String body){
15 System.out.println("LSF Message transformed");
16 producer.sendBody(body);
17 }
18
19 }