BAEL-798 - Apache Camel with Spring Boot (#1761)

* initial import

* simplified to rest only

* simplifications

* update

* Create ExampleServices.java

* Update Application.java

* simple readme

* strip of dependency management

* setting Camel versions apart where affected

* Update README.md

* update comments

* Update pom.xml

* delete of fabri8 deployment.yml

camel-api/src/main/java/com/baeldung/camel/Application.java

@@ -0,0 +1,104 @@
+package com.baeldung.camel;
+
+import javax.ws.rs.core.MediaType;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.servlet.CamelHttpTransportServlet;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.apache.camel.model.rest.RestBindingMode;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.web.servlet.ServletRegistrationBean;
+import org.springframework.boot.web.support.SpringBootServletInitializer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.stereotype.Component;
+
+@SpringBootApplication
+@ComponentScan(basePackages="com.baeldung.camel")
+public class Application extends SpringBootServletInitializer {
+
+    @Value("${server.port}")
+    String serverPort;
+    
+    @Value("${baeldung.api.path}")
+    String contextPath;
+    
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
+
+    @Bean
+    ServletRegistrationBean servletRegistrationBean() {
+        ServletRegistrationBean servlet = new ServletRegistrationBean(new CamelHttpTransportServlet(), contextPath+"/*");
+        servlet.setName("CamelServlet");
+        return servlet;
+    }
+
+
+    @Component
+    class RestApi extends RouteBuilder {
+
+        @Override
+        public void configure() {
+
+            CamelContext context = new DefaultCamelContext();
+
+            
+            // http://localhost:8080/camel/api-doc
+            restConfiguration().contextPath(contextPath) //
+                .port(serverPort)
+                .enableCORS(true)
+                .apiContextPath("/api-doc")
+                .apiProperty("api.title", "Test REST API")
+                .apiProperty("api.version", "v1")
+                .apiProperty("cors", "true") // cross-site
+                .apiContextRouteId("doc-api")
+                .component("servlet")
+                .bindingMode(RestBindingMode.json)
+                .dataFormatProperty("prettyPrint", "true");
+/** 
+The Rest DSL supports automatic binding json/xml contents to/from POJOs using Camels Data Format.
+By default the binding mode is off, meaning there is no automatic binding happening for incoming and outgoing messages.
+You may want to use binding if you develop POJOs that maps to your REST services request and response types. 
+This allows you, as a developer, to work with the POJOs in Java code.
+*/         
+            
+            rest("/api/").description("Teste REST Service")
+                .id("api-route")
+                .post("/bean")
+                .produces(MediaType.APPLICATION_JSON)
+                .consumes(MediaType.APPLICATION_JSON)
+//                .get("/hello/{place}")
+                .bindingMode(RestBindingMode.auto)
+                .type(MyBean.class)
+                .enableCORS(true)
+//                .outType(OutBean.class)
+
+                .to("direct:remoteService");
+            
+       
+            from("direct:remoteService")
+                .routeId("direct-route")
+                .tracing()
+                .log(">>> ${body.id}")
+                .log(">>> ${body.name}")
+//                .transform().simple("blue ${in.body.name}")                
+                .process(new Processor() {
+                    @Override
+                    public void process(Exchange exchange) throws Exception {
+                        MyBean bodyIn = (MyBean) exchange.getIn().getBody();
+                        
+                        ExampleServices.example(bodyIn);
+
+                        exchange.getIn().setBody(bodyIn);
+                    }
+                })
+                .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(201));
+        }
+    }
+}

camel-api/src/main/java/com/baeldung/camel/ExampleServices.java

@@ -0,0 +1,15 @@
+package com.baeldung.camel;
+
+/**
+ * a Mock class to show how some other layer
+ * (a persistence layer, for instance)
+ * could be used insida a Camel
+ * 
+ */
+public class ExampleServices {
+
+    public static void example(MyBean bodyIn) {
+        bodyIn.setName( "Hello, " + bodyIn.getName() );
+        bodyIn.setId(bodyIn.getId()*10);
+    }
+}

camel-api/src/main/java/com/baeldung/camel/MyBean.java

@@ -0,0 +1,18 @@
+package com.baeldung.camel;
+
+public class MyBean {
+    private Integer id;
+    private String name;
+    public Integer getId() {
+        return id;
+    }
+    public void setId(Integer id) {
+        this.id = id;
+    }
+    public String getName() {
+        return name;
+    }
+    public void setName(String name) {
+        this.name = name;
+    }
+}