This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit aa9a4dc5eefaafa989e59650fb78fbca803ad869 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Aug 7 13:39:37 2019 +0200 CAMEL-13792 - Rename components to default names, Camel-netty4 to camel-netty - Aligned camel-netty-correlation example --- .../src/main/java/org/apache/camel/example/netty/MyClient.java | 2 +- .../src/main/java/org/apache/camel/example/netty/MyServer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java index 4c0342b..4ce7c6a 100644 --- a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java +++ b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyClient.java @@ -82,7 +82,7 @@ public final class MyClient { .log("Request: ${id}:${body}") // call netty server using a single shared connection and using custom correlation manager // to ensure we can correltly map the request and response pairs - .to("netty4:tcp://localhost:4444?sync=true&encoders=#myEncoder&decoders=#myDecoder" + .to("netty:tcp://localhost:4444?sync=true&encoders=#myEncoder&decoders=#myDecoder" + "&producerPoolEnabled=false&correlationManager=#myManager") // log response after .log("Response: ${id}:${body}"); diff --git a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java index d56cb74..2953af8 100644 --- a/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java +++ b/examples/camel-example-netty-custom-correlation/src/main/java/org/apache/camel/example/netty/MyServer.java @@ -39,7 +39,7 @@ public final class MyServer { @Override public void configure() throws Exception { - from("netty4:tcp://localhost:4444?sync=true&encoders=#myEncoder&decoders=#myDecoder") + from("netty:tcp://localhost:4444?sync=true&encoders=#myEncoder&decoders=#myDecoder") .log("Request: ${id}:${body}") .filter(simple("${body} contains 'beer'")) // use some delay when its beer to make responses interleaved