fix: subscription annotation values

block · Dec 16, 2024 · dfecaaa · dfecaaa
1 parent 1ef0c89
commit dfecaaa
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ntime/common/deployment/src/main/java/xyz/block/ftl/deployment/SubscriptionProcessor.java b/...ntime/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(