[camel] branch master updated: Regen

[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 d1690fb  Regen
d1690fb is described below

commit d1690fb5c0be5ca6b32453cc166923ba13b452ec
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Oct 8 18:47:06 2020 +0200

    Regen
---
 .../org/apache/camel/component/rabbitmq/RabbitConsumer.java    | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java
 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java
index 71e64fa..ccfce12 100644
--- 
a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java
+++ 
b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java
@@ -129,15 +129,19 @@ class RabbitConsumer extends ServiceSupport implements 
com.rabbitmq.client.Consu
                 try {
                     consumer.getEndpoint().publishExchangeToChannel(exchange, 
channel, properties.getReplyTo());
                 } catch (AlreadyClosedException alreadyClosedException) {
-                    LOG.warn("Connection or channel closed during reply to 
exchange {} for correlationId {}. Will reconnect and try again.", 
exchange.getExchangeId(), properties.getCorrelationId());
+                    LOG.warn(
+                            "Connection or channel closed during reply to 
exchange {} for correlationId {}. Will reconnect and try again.",
+                            exchange.getExchangeId(), 
properties.getCorrelationId());
                     // RPC call could not be responded because channel (or 
connection has been closed during the processing ...
                     // will try to reconnect
                     try {
                         reconnect();
-                        LOG.debug("Sending again the reply to exchange {} for 
correlationId {}", exchange.getExchangeId(), properties.getCorrelationId());
+                        LOG.debug("Sending again the reply to exchange {} for 
correlationId {}", exchange.getExchangeId(),
+                                properties.getCorrelationId());
                         
consumer.getEndpoint().publishExchangeToChannel(exchange, channel, 
properties.getReplyTo());
                     } catch (Exception e) {
-                        LOG.error("Couldn't sending again the reply to 
exchange {} for correlationId {}", exchange.getExchangeId(), 
properties.getCorrelationId());
+                        LOG.error("Couldn't sending again the reply to 
exchange {} for correlationId {}",
+                                exchange.getExchangeId(), 
properties.getCorrelationId());
                         exchange.setException(e);
                         consumer.getExceptionHandler().handleException("Error 
processing exchange", exchange, e);
                     }