fix: subscription annotation values

block · Dec 16, 2024 · 880fbd2 · 880fbd2
1 parent 8803a38
commit 880fbd2
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(