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);
}
