diff --git a/src/main/java/io/github/hectorvent/floci/services/lambda/SqsEventSourcePoller.java b/src/main/java/io/github/hectorvent/floci/services/lambda/SqsEventSourcePoller.java index 44e7863a..7b58f932 100644 --- a/src/main/java/io/github/hectorvent/floci/services/lambda/SqsEventSourcePoller.java +++ b/src/main/java/io/github/hectorvent/floci/services/lambda/SqsEventSourcePoller.java @@ -73,7 +73,7 @@ public SqsEventSourcePoller(Vertx vertx, SqsService sqsService, void init() { List esms = esmStore.list(); for (EventSourceMapping esm : esms) { - if (esm.isEnabled()) { + if (esm.isEnabled() && esm.getEventSourceArn().contains(":sqs:")) { startPolling(esm); } }