fixed this project.

christian-posta · Mar 5, 2015 · 44e82bf · 44e82bf
1 parent b1af644
commit 44e82bf
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/pom.xml b/pom.xml
@@ -9,8 +9,8 @@
     <version>1.0-SNAPSHOT</version>
 
     <properties>
-        <camel.version>2.8.0-fuse-04-01</camel.version>
-        <cxf.version>2.4.3-fuse-02-02</cxf.version>
+        <camel.version>2.14.1</camel.version>
+        <cxf.version>3.0.2</cxf.version>
     </properties>
 
     <dependencies>
@@ -94,8 +94,8 @@
                 <artifactId>maven-compiler-plugin</artifactId>
                 <version>2.3.2</version>
                 <configuration>
-                    <source>1.6</source>
-                    <target>1.6</target>
+                    <source>1.7</source>
+                    <target>1.7</target>
                 </configuration>
             </plugin>
             <plugin>

diff --git a/src/main/java/com/fusesource/samples/CustomerServiceProcessor.java b/src/main/java/com/fusesource/samples/CustomerServiceProcessor.java
@@ -44,7 +44,7 @@ public void process(Exchange exchange) throws Exception {
         Message inMessage = exchange.getIn();
         String operationName = inMessage.getHeader(CxfConstants.OPERATION_NAME, String.class);
         if ("getCustomer".equalsIgnoreCase(operationName)) {
-            String id = inMessage.getHeader("OrigId", String.class);
+            String id = inMessage.getBody(String.class);
             LOG.info("----invoking getCustomer, Customer id is: " + id);
 
             long idNumber = Long.parseLong(id);
@@ -57,7 +57,7 @@ public void process(Exchange exchange) throws Exception {
                 exchange.getOut().setBody(response);
             }
 
-//            exchange.getOut().setBody(c);
+            exchange.getOut().setBody(c);
 
 
         }

diff --git a/src/main/java/com/fusesource/samples/CustomerServiceRoute.java b/src/main/java/com/fusesource/samples/CustomerServiceRoute.java
@@ -19,7 +19,7 @@ public void configure() throws Exception {
 //        from("cxfrs:bean:rsServer")
         from("cxfrs://http://localhost:9090/route?resourceClasses=com.fusesource.samples.CustomerServiceResource")
                 .setHeader(Exchange.FILE_NAME, simple("test-${body}.xml"))
-                .pollEnrich("file:src/data?noop=true", 1000, new CustomerEnricher())
+//                .pollEnrich("file:src/data?noop=true", 1000, new CustomerEnricher())
                 .process(new CustomerServiceProcessor())
                 .log("Here is the message that was enriched: ${body}");
     }