Re: camel aggregator 2.2 xpath based routing not working

[alexcpn <al...@gmail.com>]

I just printed out the body of the exchange in the camel aggregator and it is
returning null !
 I guess this is one reason why the xpath is not working during aggregation.
Could this be a bug in camel 2.2 ?

Here are two snippets; one just printing the expected body as is , and the
second which routes it through the aggregator
-------------------------------------------------------------------------------------------------------
public class MyRouteBuilder extends RouteBuilder {

   public void configure() {
	System.out.println("In MyRouteBuilder------------------");
       	
	Namespaces ns = new Namespaces("p", "http://nsn.com/obs/mw/medfra/snmpbc")
       	.add("xsd", "http://www.w3.org/2001/XMLSchema");
		
from("jbi:service:http://servicemix.apache.org/test/camel-receiver")
   	.to("log:tutorial");  

-------------------------------------------------------------------------------------------------------
INFO  - AutoDeploymentService          - Directory: hotdeploy: Finished
installation of archive:  inmc-snmp-sa-1.0-SNAPSHOT.jar
INFO  - tutorial                       -
Exchange[BodyType:javax.xml.transform.stream.StreamSource,
 Body:<p:snmp-getResponse xmlns:p="http://nsn.com/obs/mw/medf
ra/snmpbc" xmlns:xsi="http://www.w3.org/2001/XMLSchema">
  <p:NE ipaddr="10.58.128.10"/>
  <p:get-response> 1.3.6.1.6.3.1.1.4.1.0
    <p:variable-bindings>
      <p:varBinding name="1.3.6.1.6.3.1.1.4.1.0">noSuchObject</p:varBinding>
     </p:variable-bindings>
  </p:get-response>
</p:snmp-getResponse>
------------------------------------------------------------------------------------------------------------------

public class MyRouteBuilder extends RouteBuilder {
		
    public void configure() {
 	from("jbi:service:http://servicemix.apache.org/test/camel-receiver")
       	.aggregate(new MyAggregationStrategy()) //camel 2
    	//.aggregator(new MyAggregationStrategy()) //camel 1.6
    	.header("*")
    	//.xpath("string(/p:snmp-getResponse/p:NE/@ipaddr)",String.class, ns)
    	//.completedPredicate(header("completed").isEqualTo("true")) //camel
1.6
		.completionPredicate(header("completed").isEqualTo("true")) //camel 2
	
//.to("jbi:endpoint:http://servicemix.apache.org/test/file_sender_getbulk/endpoint"); 
// 3 
		.to("log:tutorial");  

-------------------------------------------------------------------------------------------------------

public class MyAggregationStrategy implements AggregationStrategy {

public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {


String oldBody = oldExchange.getIn().getBody(String.class);
String newBody = newIn.getBody(String.class);

System.out.println("---------------------------");
System.out.println("New Body "+newBody);
System.out.println("Old Body "+oldBody);
System.out.println("---------------------------");

String oldBody2 = oldExchange.getOut().getBody(String.class);
String newBody2 = newExchange.getOut().getBody(String.class);

System.out.println("---------------------------");
System.out.println("New Body Out "+newBody2);
System.out.println("Old Body  Out "+oldBody2);
System.out.println("---------------------------");

-------------------------------------------------------------------------------------
INFO  - AutoDeploymentService          - Directory: hotdeploy: Finis
tion of archive:  inmc-snmp-sa-1.0-SNAPSHOT.jar
Going in aggregate 123i4
Exception in Aggregator
java.lang.NullPointerException
Going in aggregate 123i4
---------------------------
New Body null
Old Body null
---------------------------
---------------------------
New Body Out null
Old Body  Out null
---------------------------
getIp - inXMLnull
Exception caught getIp java.lang.NullPointerException
Ip-->
Status-->
Exception in Aggregator
java.lang.NumberFormatException: For input string: ""

-- 
View this message in context: http://camel.465427.n5.nabble.com/camel-aggregator-2-2-xpath-based-routing-not-working-tp2840127p2840432.html
Sent from the Camel - Users mailing list archive at Nabble.com.