Fix tests

michelin · Aug 4, 2024 · cabd64a · cabd64a
1 parent c386b89
commit cabd64a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kstreamplify-core/src/main/java/com/michelin/kstreamplify/server/KafkaStreamsHttpServer.java b/kstreamplify-core/src/main/java/com/michelin/kstreamplify/server/KafkaStreamsHttpServer.java
@@ -144,8 +144,9 @@ private Object getResponseForStoreEndpoints(HttpExchange exchange) {
             return interactiveQueriesService.getStateStores();
         }
 
-        String store = parsePathParam(exchange, 3);
+        String store;
         if (exchange.getRequestURI().toString().matches("/" + DEFAULT_STORE_PATH + "/metadata/.*")) {
+            store = parsePathParam(exchange, 3);
             return interactiveQueriesService.getStreamsMetadataForStore(store)
                 .stream()
                 .map(streamsMetadata -> new StreamsMetadata(
@@ -156,6 +157,7 @@ private Object getResponseForStoreEndpoints(HttpExchange exchange) {
         }
 
         if (exchange.getRequestURI().toString().matches("/" + DEFAULT_STORE_PATH + "/local/.*")) {
+            store = parsePathParam(exchange, 3);
             return interactiveQueriesService.getAllOnLocalhost(store);
         }