You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/08/07 13:10:44 UTC
[camel] 12/20: CAMEL-13792 - Rename components to default names,
Camel-netty4 to camel-netty - Aligned camel-netty-correlation
example
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 <an...@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