GH-187 INFO for error when KinesisChA is inactive
Fixes https://github.com/spring-projects/spring-integration-aws/issues/187
This commit is contained in:
@@ -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;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user