completed tutorial

Author: TheCookieLab

Diff for: logs/logs.txt

@@ -28,9 +28,9 @@ public static void main(String[] args) throws InterruptedException  {
 
             context.start();
 
+            final long sleepDurationInMs = 1000;
             for (int i = 0; i < 600; i++)
-            {
-                final long sleepDurationInMs = 1000;
+            {                
                 Thread.sleep(sleepDurationInMs);
             }
 

Diff for: src/main/java/com/cf/helloworld/Main.java

@@ -1,20 +1,12 @@
-/*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
 package com.cf.helloworld.processor;
-
+import com.cf.helloworld.response.CustomerDetailResponse;
+import java.util.Date;
 import java.util.Map;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/**
- *
- * @author David Pang
- */
 public class DefaultGetProcessor implements Processor
 {
 
@@ -25,9 +17,9 @@ public void process(Exchange ex) throws Exception
     {
         final long startTime = System.currentTimeMillis();
         logger.debug("Processing exchange - " + ex.toString());
-        final String body = ex.getIn().getBody(String.class);
+        final String request = ex.getIn().getBody(String.class);
         final Map<String, Object> headers = ex.getIn().getHeaders();
-
+        
         final Object id = headers.get("id");     
         logger.debug("ID: " + id);
 
@@ -41,9 +33,12 @@ public void process(Exchange ex) throws Exception
 
         }
         logger.debug("Headers: " + sb.toString());
+        
+        // Construct output
+        CustomerDetailResponse response = new CustomerDetailResponse(id.toString(), "Billy Bob", "[email protected]", new Date());
 
         ex.getOut().setHeaders(ex.getIn().getHeaders());
-        ex.getOut().setBody("DefaultGetProcessor processing complete");
+        ex.getOut().setBody(response);
         logger.info("DefaultPostProcessor process() completed in " + (System.currentTimeMillis() - startTime) + " ms");
     }
 

Diff for: src/main/java/com/cf/helloworld/processor/DefaultGetProcessor.java

@@ -5,10 +5,7 @@
  */
 package com.cf.helloworld.processor;
 
-import java.util.ArrayList;
-import java.util.List;
 import java.util.Map;
-import java.util.Map.Entry;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.slf4j.Logger;

Diff for: src/main/java/com/cf/helloworld/processor/DefaultPostProcessor.java

@@ -0,0 +1,19 @@
+package com.cf.helloworld.response;
+
+import java.util.Date;
+
+public class CustomerDetailResponse
+{
+    public final String id;
+    public final String name;
+    public final String emailAddress;
+    public final Date birthday;
+    
+    public CustomerDetailResponse(String id, String name, String emailAddress, Date birthday)
+    {
+        this.id = id;
+        this.name = name;
+        this.emailAddress = emailAddress;
+        this.birthday = birthday;
+    }
+}

Diff for: src/main/java/com/cf/helloworld/response/CustomerDetailResponse.java

@@ -1,8 +1,3 @@
-/*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
 package com.cf.helloworld.route;
 
 import com.cf.helloworld.processor.DefaultGetProcessor;
@@ -11,13 +6,8 @@
 import org.apache.camel.model.dataformat.JsonLibrary;
 import org.apache.camel.model.rest.RestBindingMode;
 
-/**
- *
- * @author David Pang
- */
 public class RouteBuilderImpl extends RouteBuilder
 {
-
     @Override
     public void configure() throws Exception
     {