From dfecaaaa4783cee584f61ee78d04e3917bf5268f Mon Sep 17 00:00:00 2001 From: Stuart Douglas Date: Mon, 16 Dec 2024 12:26:27 +1100 Subject: [PATCH] fix: subscription annotation values --- .../java/xyz/block/ftl/deployment/SubscriptionProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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(