tiennm99/java-design-patterns
1
0
Fork 0
mirror of https://github.com/tiennm99/java-design-patterns.git synced 2026-05-20 16:23:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

dependencies: upgrade Camel 2.25.1 to 3.18.1 (#2318)

Browse Source
This commit is contained in:
Robert Volkmann
2022-11-20 13:29:17 +01:00
committed by GitHub
parent c4307db0a6
commit 2f71c41af0
6 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
eip-aggregator/src/main/java/com/iluwatar/eip/aggregator/routes/MessageAggregationStrategy.java
+1 -1
View File
@@ -24,8 +24,8 @@
*/
package com.iluwatar.eip.aggregator.routes;
import org.apache.camel.AggregationStrategy;
import org.apache.camel.Exchange;
import org.apache.camel.processor.aggregate.AggregationStrategy;
import org.springframework.stereotype.Component;
/**
eip-aggregator/src/test/java/com/iluwatar/eip/aggregator/routes/MessageAggregationStrategyTest.java
+7 -4
View File
@@ -27,7 +27,8 @@ package com.iluwatar.eip.aggregator.routes;
import static org.junit.jupiter.api.Assertions.assertEquals;
import org.apache.camel.CamelContext;
import org.apache.camel.impl.DefaultExchange;
import org.apache.camel.impl.engine.SimpleCamelContext;
import org.apache.camel.support.DefaultExchange;
import org.junit.jupiter.api.Test;
/**
@@ -35,13 +36,15 @@ import org.junit.jupiter.api.Test;
*/
class MessageAggregationStrategyTest {
private final CamelContext context = new SimpleCamelContext();
@Test
void testAggregate() {
var mas = new MessageAggregationStrategy();
var oldExchange = new DefaultExchange((CamelContext) null);
var oldExchange = new DefaultExchange(context);
oldExchange.getIn().setBody("TEST1");
var newExchange = new DefaultExchange((CamelContext) null);
var newExchange = new DefaultExchange(context);
newExchange.getIn().setBody("TEST2");
var output = mas.aggregate(oldExchange, newExchange);
@@ -53,7 +56,7 @@ class MessageAggregationStrategyTest {
void testAggregateOldNull() {
var mas = new MessageAggregationStrategy();
var newExchange = new DefaultExchange((CamelContext) null);
var newExchange = new DefaultExchange(context);
newExchange.getIn().setBody("TEST2");
var output = mas.aggregate(null, newExchange);