[camel] branch master updated: CAMEL-12427: camel-netty4 - Add SPI to plugin custom correlation state for request/reply in producer

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 82a57c9  CAMEL-12427: camel-netty4 - Add SPI to plugin custom 
correlation state for request/reply in producer
82a57c9 is described below

commit 82a57c9dc5d2d134fee45a2902bad90115a3d750
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Apr 10 09:47:34 2018 +0200

    CAMEL-12427: camel-netty4 - Add SPI to plugin custom correlation state for 
request/reply in producer
---
 .../component/netty4/NettyCustomCorrelationManagerTest.java    | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyCustomCorrelationManagerTest.java
 
b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyCustomCorrelationManagerTest.java
index 35b2d6b..9925a98 100644
--- 
a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyCustomCorrelationManagerTest.java
+++ 
b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyCustomCorrelationManagerTest.java
@@ -18,8 +18,6 @@ package org.apache.camel.component.netty4;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
-import org.apache.camel.Exchange;
-import org.apache.camel.Predicate;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.impl.JndiRegistry;
@@ -64,7 +62,7 @@ public class NettyCustomCorrelationManagerTest extends 
BaseNettyTest {
             public void configure() throws Exception {
                 from("seda:start")
                     .log("before ${body}")
-                    
.to("netty4:tcp://localhost:{{port}}?textline=true&sync=true&correlationManager=#myManager")
+                    
.to("netty4:tcp://localhost:{{port}}?textline=true&sync=true&producerPoolEnabled=false&correlationManager=#myManager")
                     .log("after ${body}")
                     .to("mock:result");
 
@@ -79,9 +77,15 @@ public class NettyCustomCorrelationManagerTest extends 
BaseNettyTest {
         private volatile NettyCamelState stateA;
         private volatile NettyCamelState stateB;
         private volatile NettyCamelState stateC;
+        private volatile Channel channel;
 
         @Override
         public void putState(Channel channel, NettyCamelState state) {
+            if (this.channel != null && this.channel != channel) {
+                throw new IllegalStateException("Should use same channel as 
producer pool is disabled");
+            }
+            this.channel = channel;
+
             String body = 
state.getExchange().getMessage().getBody(String.class);
             if ("A".equals(body)) {
                 stateA = state;

-- 
To stop receiving notification emails like this one, please contact
davscl...@apache.org.