From 0b223369edba32ea43a9b2d439b1ef39d8bb8caa Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 4 Jun 2021 11:03:14 -0400 Subject: [PATCH] Fix Sonar Issue --- .../integration/kafka/inbound/KafkaInboundGateway.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java index 2aa42ad9f4..3d502cbe24 100644 --- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java +++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java @@ -48,6 +48,7 @@ import org.springframework.kafka.support.converter.ConversionException; import org.springframework.kafka.support.converter.KafkaMessageHeaders; import org.springframework.kafka.support.converter.RecordMessageConverter; import org.springframework.messaging.Message; +import org.springframework.messaging.MessageChannel; import org.springframework.messaging.MessageHeaders; import org.springframework.retry.RecoveryCallback; import org.springframework.retry.RetryCallback; @@ -285,8 +286,9 @@ public class KafkaInboundGateway extends MessagingGatewaySupport implem setAttributesIfNecessary(record, message); } catch (RuntimeException e) { - if (getErrorChannel() != null) { - KafkaInboundGateway.this.messagingTemplate.send(getErrorChannel(), buildErrorMessage(null, + MessageChannel errorChannel = getErrorChannel(); + if (errorChannel != null) { + KafkaInboundGateway.this.messagingTemplate.send(errorChannel, buildErrorMessage(null, new ConversionException("Failed to convert to message", record, e))); } }