[camel] branch exchange-factory updated: CAMEL-16222: PooledExchangeFactory experiment

[davsclaus]

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

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


The following commit(s) were added to refs/heads/exchange-factory by this push:
     new 8b894c2  CAMEL-16222: PooledExchangeFactory experiment
8b894c2 is described below

commit 8b894c2fec2067197fc5f090ab79ae8ed064cccd
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sun Feb 21 09:04:50 2021 +0100

    CAMEL-16222: PooledExchangeFactory experiment
---
 .../apache/camel/processor/PooledExchangeTest.java | 31 +++++++++++-----------
 1 file changed, 15 insertions(+), 16 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java
index ca8fa4c..f771dc9 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java
@@ -29,7 +29,6 @@ import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.impl.engine.PooledExchangeFactory;
 import org.junit.jupiter.api.Test;
 
-
 import static org.junit.jupiter.api.Assertions.assertSame;
 
 public class PooledExchangeTest extends ContextTestSupport {
@@ -64,22 +63,22 @@ public class PooledExchangeTest extends ContextTestSupport {
             @Override
             public void configure() throws Exception {
                 
from("timer:foo?period=1&delay=1&repeatCount=2").noAutoStartup()
-                    .setProperty("myprop", counter::incrementAndGet)
-                    .setHeader("myheader", counter::incrementAndGet)
-                    .process(new Processor() {
-                        @Override
-                        public void process(Exchange exchange) throws 
Exception {
-                            // should be same exchange instance as its pooled
-                            Exchange old = ref.get();
-                            if (old == null) {
-                                ref.set(exchange);
-                                exchange.getMessage().setHeader("first", true);
-                            } else {
-                                assertSame(old, exchange);
+                        .setProperty("myprop", counter::incrementAndGet)
+                        .setHeader("myheader", counter::incrementAndGet)
+                        .process(new Processor() {
+                            @Override
+                            public void process(Exchange exchange) throws 
Exception {
+                                // should be same exchange instance as its 
pooled
+                                Exchange old = ref.get();
+                                if (old == null) {
+                                    ref.set(exchange);
+                                    exchange.getMessage().setHeader("first", 
true);
+                                } else {
+                                    assertSame(old, exchange);
+                                }
                             }
-                        }
-                    })
-                    .to("mock:result");
+                        })
+                        .to("mock:result");
             }
         };
     }