1 package org.srinivas.siteworks.dbrestserver;
2
3 import java.io.StringWriter;
4 import java.util.ArrayList;
5
6 import org.apache.camel.Exchange;
7 import org.apache.camel.Processor;
8 import org.slf4j.Logger;
9 import org.slf4j.LoggerFactory;
10 import org.srinivas.siteworks.dbrestserver.utilities.DbRestServerUtility;
11 import org.srinivas.siteworks.dbrestserver.utilities.FireWork;
12 import org.srinivas.siteworks.dbrestserver.utilities.FireWorks;
13 import org.srinivas.siteworks.dbrestserver.utilities.FireWorksService;
14
15
16
17
18 public class FireWorksListProcessor implements Processor {
19 private static final Logger log = LoggerFactory.getLogger(FireWorksListProcessor.class);
20
21
22
23
24 @Override
25 public void process(Exchange exchange) throws Exception {
26 log.info("Processing with FireWorksListProcessor");
27 StringWriter stringWriter = new StringWriter();
28 FireWorksService dataService = new FireWorksService();
29 FireWorks fireworks = new FireWorks();
30 fireworks.setFireworks(new ArrayList<FireWork>(dataService.listFireWorks()));
31 DbRestServerUtility.fireWorksCollectionToXML(fireworks, stringWriter);
32 exchange.getIn().setBody(stringWriter.toString());
33 }
34 }