1
2
3
4
5 package org.srinivas.siteworks.rlrestserver.webconfig;
6
7 import java.io.Writer;
8 import javax.servlet.http.HttpServletRequest;
9 import javax.servlet.http.HttpServletResponse;
10 import org.apache.camel.ProducerTemplate;
11 import org.apache.commons.io.IOUtils;
12 import org.slf4j.Logger;
13 import org.slf4j.LoggerFactory;
14 import org.springframework.web.bind.annotation.RequestMapping;
15 import org.springframework.web.bind.annotation.RequestMethod;
16 import org.springframework.web.bind.annotation.RestController;
17 import static org.srinivas.siteworks.rlrestserver.RLRestServerRoute.*;
18
19
20
21
22 @RestController
23 public class RLRestServerController {
24 private static final Logger log = LoggerFactory.getLogger(RLRestServerController.class);
25
26
27
28
29
30
31
32
33 @RequestMapping(value = "/fireworks/getAll")
34 public void restPage(HttpServletRequest request, Writer writer) throws Exception {
35 log.info("RLRestServerController restPage RestPath:" + "fireworks/getAll");
36 ProducerTemplate template = RLRestServerCamelListener.getContext().createProducerTemplate();
37 String result = template.requestBody(CAMEL_ENDPOINT_DIRECT_START, "fireworks/getAll", String.class);
38 writer.write(result);
39 }
40
41
42
43
44
45
46
47
48
49 @RequestMapping(value = "/fireworks/updatefirework", method = RequestMethod.POST)
50 public void restUpdatePage(HttpServletRequest request, HttpServletResponse response, Writer writer) throws Exception {
51 log.info("RLRestserver RLRestServerController restUpdatePage");
52 String payload = IOUtils.toString(request.getReader());
53 ProducerTemplate template = RLRestServerCamelListener.getContext().createProducerTemplate();
54 String result = template.requestBodyAndHeader(CAMEL_ENDPOINT_DIRECT_START, "fireworks/updatefirework", "fireworkupdatekey", payload, String.class);
55 log.info("resultprint at RLRestserver" + result);
56 writer.write(result);
57 }
58
59 }