fix java test code

block · Dec 16, 2024 · 039efcb · 039efcb
1 parent 880fbd2
commit 039efcb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/backend/runner/pubsub/testdata/go/publisher/types.ftl.go b/backend/runner/pubsub/testdata/go/publisher/types.ftl.go
diff --git a/...testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java b/...testdata/java/subscriber/src/main/java/xyz/block/ftl/java/test/subscriber/Subscriber.java
@@ -1,7 +1,5 @@
 package xyz.block.ftl.java.test.subscriber;
 
-import java.util.concurrent.atomic.AtomicInteger;
-
 import ftl.publisher.PubSubEvent;
 import ftl.publisher.TestTopicTopic;
 import ftl.publisher.Topic2Topic;
@@ -21,7 +19,7 @@ void consume(PubSubEvent event) throws Exception {
     void consumeFromLatest(PubSubEvent event) throws Exception {
     }
 
-    ConsumeFromLatest
+    @Subscription(topic = Topic2Topic.class, from = FromOffset.BEGINNING)
     @Retry(count = 2, minBackoff = "1s", maxBackoff = "1s")
     public void consumeButFailAndRetry(PubSubEvent event) {
         throw new RuntimeException("always error: event " + event.getTime());