ability to disable kinesis listener processing (#187)

agorapulse · Sep 19, 2023 · b41265d · b41265d
1 parent 4839c43
commit b41265d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...com/agorapulse/micronaut/amazon/awssdk/kinesis/worker/KinesisListenerMethodProcessor.java b/...com/agorapulse/micronaut/amazon/awssdk/kinesis/worker/KinesisListenerMethodProcessor.java
@@ -44,9 +44,8 @@
 import java.util.function.BiConsumer;
 
 @Singleton
-@Requires(
-    property = "aws.kinesis"
-)
+@Requires(property = "aws.kinesis")
+@Requires(property = "aws.kinesis.listener.enabled", value = StringUtils.TRUE, defaultValue = StringUtils.TRUE)
 public class KinesisListenerMethodProcessor implements ExecutableMethodProcessor<KinesisListener>, ApplicationEventListener<ShutdownEvent>, Closeable {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(KinesisListenerMethodProcessor.class);

diff --git a/...in/groovy/com/agorapulse/micronaut/aws/kinesis/worker/KinesisListenerMethodProcessor.java b/...in/groovy/com/agorapulse/micronaut/aws/kinesis/worker/KinesisListenerMethodProcessor.java
@@ -48,6 +48,7 @@
     property = "aws.kinesis",
     classes = KinesisClientLibConfiguration.class
 )
+@Requires(property = "aws.kinesis.listener.enabled", value = StringUtils.TRUE, defaultValue = StringUtils.TRUE)
 public class KinesisListenerMethodProcessor implements ExecutableMethodProcessor<KinesisListener>, ApplicationEventListener<ShutdownEvent> {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(KinesisListener.class);