diff --git a/echo-pubsub-aws/src/main/java/com/netflix/spinnaker/echo/pubsub/aws/SQSSubscriber.java b/echo-pubsub-aws/src/main/java/com/netflix/spinnaker/echo/pubsub/aws/SQSSubscriber.java index 8e48fbf51..de60902b5 100644 --- a/echo-pubsub-aws/src/main/java/com/netflix/spinnaker/echo/pubsub/aws/SQSSubscriber.java +++ b/echo-pubsub-aws/src/main/java/com/netflix/spinnaker/echo/pubsub/aws/SQSSubscriber.java @@ -113,7 +113,12 @@ public String getName() { @Override public void run() { log.info("Starting " + getWorkerName()); - initializeQueue(); + try { + initializeQueue(); + } catch (Exception e) { + log.error("Error initializing queue {}", queueARN, e); + throw e; + } while (true) { try {