diff --git a/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java b/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java index bbf9685a9d..fc0cfd2f22 100644 --- a/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java +++ b/jvm-runtime/ftl-runtime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java @@ -85,9 +85,9 @@ public static SubscriptionAnnotation fromJandex(IndexView indexView, AnnotationI } topicName = annotation.value().asString(); AnnotationValue moduleValue = annotation.value("module"); - AnnotationValue deadLetterValue = annotation.value("deadLetter"); + AnnotationValue deadLetterValue = subscriptions.value("deadLetter"); boolean deadLetter = deadLetterValue != null && !deadLetterValue.asString().isEmpty() && deadLetterValue.asBoolean(); - AnnotationValue from = annotation.value("from"); + AnnotationValue from = subscriptions.value("from"); FromOffset fromOffset = from == null ? FromOffset.LATEST : FromOffset.valueOf(from.asEnum()); return new SubscriptionAnnotation(