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

[davsclaus-2]

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 a3e0f3c  CAMEL-16222: PooledExchangeFactory experiment
a3e0f3c is described below

commit a3e0f3ce3e91d08d8032dd9837904a4c105d9950
Author: Claus Ibsen <[hidden email]>
AuthorDate: Tue Feb 23 09:17:23 2021 +0100

    CAMEL-16222: PooledExchangeFactory experiment
---
 .../java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java     | 3 ++-
 .../java/org/apache/camel/component/rabbitmq/RabbitMQConsumerTest.java | 3 ---
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java
index 1e85c18..4a0869f 100644
--- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java
+++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java
@@ -131,7 +131,8 @@ public class RabbitMQConsumer extends DefaultConsumer implements Suspendable {
 
     public Exchange createExchange(Envelope envelope, AMQP.BasicProperties properties, byte[] body) {
         Exchange exchange = createExchange(false);
-        endpoint.getMessageConverter().populateRabbitExchange(exchange, envelope, properties, body, false, endpoint.isAllowMessageBodySerialization());
+        endpoint.getMessageConverter().populateRabbitExchange(exchange, envelope, properties, body, false,
+                endpoint.isAllowMessageBodySerialization());
         return exchange;
     }
 
diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerTest.java
index 79d2e11..5ec8688 100644
--- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerTest.java
+++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQConsumerTest.java
@@ -29,10 +29,7 @@ import org.apache.camel.Processor;
 import org.apache.camel.spi.ExchangeFactory;
 import org.apache.camel.spi.ExecutorServiceManager;
 import org.junit.jupiter.api.Test;
-import org.mockito.Mock;
 import org.mockito.Mockito;
-import org.mockito.invocation.InvocationOnMock;
-import org.mockito.stubbing.Answer;
 
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertTrue;