Fix "Streams with subject not found" error when creatind a pull-based…

… subscription
boomerang-io · Jan 25, 2022 · 04778e0 · 04778e0
1 parent efaba0a
commit 04778e0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/io/boomerang/eventing/nats/jetstream/PubSubTransceiver.java b/src/main/java/io/boomerang/eventing/nats/jetstream/PubSubTransceiver.java
@@ -258,7 +258,8 @@ private void startPullBasedConsumerSubscription(Connection connection)
     // Create pull subscription options and subscriber itself
     PullSubscribeOptions options =
         PullSubscribeOptions.builder().durable(consumerConfiguration.getDurable()).build();
-    JetStreamSubscription subscription = connection.jetStream().subscribe(">", options);
+    String anySubject = streamConfiguration.getSubjects().stream().findAny().orElse(">");
+    JetStreamSubscription subscription = connection.jetStream().subscribe(anySubject, options);
     PubSubTunnel tunnel = this;
     jetstreamSubscription = subscription;