(streampipes) branch remove-supported-grounding updated: Set http mode to default

[riemer]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch remove-supported-grounding
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/remove-supported-grounding by 
this push:
     new 40d0de330b Set http mode to default
40d0de330b is described below

commit 40d0de330b24331c4ed95db25c78730cf13c5c0d
Author: Dominik Riemer <dominik.rie...@gmail.com>
AuthorDate: Wed Mar 18 20:56:41 2026 +0100

    Set http mode to default
---
 .../main/java/org/apache/streampipes/commons/constants/Envs.java    | 6 +++---
 .../apache/streampipes/commons/environment/DefaultEnvironment.java  | 5 +++++
 .../org/apache/streampipes/commons/environment/Environment.java     | 2 ++
 3 files changed, 10 insertions(+), 3 deletions(-)

diff --git 
a/streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/Envs.java
 
b/streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/Envs.java
index 0a8c4680c8..d43f2e23a1 100644
--- 
a/streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/Envs.java
+++ 
b/streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/Envs.java
@@ -99,11 +99,11 @@ public enum Envs {
 
   SP_NATS_HOST("SP_NATS_HOST", "nats"),
   SP_NATS_PORT("SP_NATS_PORT", "4222"),
+  SP_NATS_TOKEN("SP_NATS_TOKEN", ""),
 
   SP_PULSAR_URL("SP_PULSAR_URL", "pulsar://localhost:6650"),
-  // TODO just for CI testing (default auto/http)
-  SP_CORE_EXTENSION_TRANSPORT_MODE("SP_CORE_EXTENSION_TRANSPORT_MODE", "nats"),
-  SP_EXTENSION_TRANSPORT_MODE("SP_EXTENSION_TRANSPORT_MODE", "nats"),
+  SP_CORE_EXTENSION_TRANSPORT_MODE("SP_CORE_EXTENSION_TRANSPORT_MODE", "auto"),
+  SP_EXTENSION_TRANSPORT_MODE("SP_EXTENSION_TRANSPORT_MODE", "http"),
   SP_EXTENSION_REQUEST_TOPIC_PREFIX(
       "SP_EXTENSION_REQUEST_TOPIC_PREFIX",
       "sp.extensions.request"
diff --git 
a/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/DefaultEnvironment.java
 
b/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/DefaultEnvironment.java
index 5ff5b0e568..76799749d6 100644
--- 
a/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/DefaultEnvironment.java
+++ 
b/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/DefaultEnvironment.java
@@ -307,6 +307,11 @@ public class DefaultEnvironment implements Environment {
     return new IntEnvironmentVariable(Envs.SP_NATS_PORT);
   }
 
+  @Override
+  public StringEnvironmentVariable getNatsToken() {
+    return new StringEnvironmentVariable(Envs.SP_NATS_TOKEN);
+  }
+
   @Override
   public StringEnvironmentVariable getPulsarUrl() {
     return new StringEnvironmentVariable(Envs.SP_PULSAR_URL);
diff --git 
a/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environment.java
 
b/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environment.java
index e0e52234b6..3bf54cce08 100644
--- 
a/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environment.java
+++ 
b/streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environment.java
@@ -154,6 +154,8 @@ public interface Environment {
 
   IntEnvironmentVariable getNatsPort();
 
+  StringEnvironmentVariable getNatsToken();
+
   StringEnvironmentVariable getPulsarUrl();
 
   StringEnvironmentVariable getCoreExtensionTransportMode();