Skip to content

Instantly share code, notes, and snippets.

@tonfever
Created July 17, 2019 04:58
Show Gist options
  • Save tonfever/39bdb94b24808543fe8b021b9c1266c1 to your computer and use it in GitHub Desktop.
Save tonfever/39bdb94b24808543fe8b021b9c1266c1 to your computer and use it in GitHub Desktop.
Camel sample of multiplecast test
public class MulticastTest extends CamelTestSupport {
@Override
public boolean isUseRouteBuilder() {
return true;
}
@Override
protected RoutesBuilder createRouteBuilder() {
return routeBuilder(routeBuilder -> {
routeBuilder.from("direct:test")
.multicast(new ResponseJsonAggregationStrategy(), false)
.to("direct:test2"
, "direct:test3");
routeBuilder.from("direct:test2").log("TEST2");
routeBuilder.from("direct:test3").log("TEST3");
});
}
@Test
void testMulticasting() throws IOException {
Exchange exchange = new DefaultExchange(this.context);
Message message = exchange.getIn();
message.setHeader("testClass", getClass().getName());
message.setBody("TEST");
template.send("direct:test", exchange);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment