From c15e345470f6b56abc95b2c1c3198e777c1e211f Mon Sep 17 00:00:00 2001
From: jkatnik <jkatnik@users.noreply.github.com>
Date: Fri, 18 Dec 2020 16:15:54 +0100
Subject: [PATCH] GH-187 INFO for error when KinesisChA is inactive

Fixes https://github.com/spring-projects/spring-integration-aws/issues/187
---
 .../kinesis/KinesisMessageDrivenChannelAdapter.java      | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
index f386713..1801a12 100644
--- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
+++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
@@ -671,7 +671,14 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport
 			if (interruptThread) {
 				Thread.currentThread().interrupt();
 			}
-			logger.error(error.getMessage(), e);
+
+			if (this.active) {
+				logger.error(error.getMessage(), e);
+			}
+			else {
+				logger.info(error.getMessage() + " while adapter was inactive", e);
+			}
+
 			throw error;
 		}
 	}