working
This commit is contained in:
@@ -14,9 +14,7 @@ public class MyAggregator implements AggregationStrategy {
|
|||||||
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
|
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
|
||||||
|
|
||||||
HashMap oldEx = (HashMap) oldExchange.getIn().getBody();
|
HashMap oldEx = (HashMap) oldExchange.getIn().getBody();
|
||||||
System.out.println(oldEx);
|
|
||||||
ArrayList<HashMap> newEx = (ArrayList) newExchange.getIn().getBody();
|
ArrayList<HashMap> newEx = (ArrayList) newExchange.getIn().getBody();
|
||||||
System.out.println(newEx);
|
|
||||||
oldEx.put("packages", newEx);
|
oldEx.put("packages", newEx);
|
||||||
|
|
||||||
MaterialType material = new MaterialType();
|
MaterialType material = new MaterialType();
|
||||||
@@ -41,8 +39,6 @@ public class MyAggregator implements AggregationStrategy {
|
|||||||
|
|
||||||
Exchange result = oldExchange;
|
Exchange result = oldExchange;
|
||||||
result.getIn().setBody(material);
|
result.getIn().setBody(material);
|
||||||
System.out.println(result.getIn().getBody());
|
|
||||||
|
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,4 @@
|
|||||||
|
/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/DAO.java
|
||||||
|
/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MyBuilder.java
|
||||||
|
/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/MyAggregator.java
|
||||||
|
/home/igor/Documents/Jacek/jacek-and-igor/src/main/java/com/release11/Main.java
|
||||||
Reference in New Issue
Block a user