fix consumer not found

ls1intum · Oct 27, 2024 · c1ed5d0 · c1ed5d0
1 parent fb161fe
commit c1ed5d0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...plication-server/src/main/java/de/tum/in/www1/hephaestus/syncing/NatsConsumerService.java b/...plication-server/src/main/java/de/tum/in/www1/hephaestus/syncing/NatsConsumerService.java
@@ -107,7 +107,11 @@ private void setupConsumer(Connection connection) throws IOException, Interrupte
 
             // Check if consumer already exists
             if (durableConsumerName != null && !durableConsumerName.isEmpty()) {
-                consumerContext = streamContext.getConsumerContext(durableConsumerName);
+                try {
+                    consumerContext = streamContext.getConsumerContext(durableConsumerName);
+                } catch (JetStreamApiException e) {
+                    consumerContext = null;
+                }
             }
 
             if (consumerContext == null) {