spotless

vectorize-io · Aug 20, 2024 · 36458e2 · 36458e2
1 parent bf07541
commit 36458e2
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 21 deletions.
diff --git a/langstream-api/src/main/java/ai/langstream/api/runner/code/AgentCodeAndLoader.java b/langstream-api/src/main/java/ai/langstream/api/runner/code/AgentCodeAndLoader.java
@@ -134,8 +134,8 @@ public void start() throws Exception {
             }
 
             @Override
-            public void close() throws Exception {
-                executeWithContextClassloader(AgentCode::close);
+            public void close() {
+                executeNoExceptionWithContextClassloader(AgentCode::close);
             }
 
             @Override
@@ -197,8 +197,8 @@ public void start() throws Exception {
             }
 
             @Override
-            public void close() throws Exception {
-                executeWithContextClassloader(AgentCode::close);
+            public void close() {
+                executeNoExceptionWithContextClassloader(AgentCode::close);
             }
 
             @Override
@@ -259,8 +259,8 @@ public void start() throws Exception {
             }
 
             @Override
-            public void close() throws Exception {
-                executeWithContextClassloader(AgentCode::close);
+            public void close() {
+                executeNoExceptionWithContextClassloader(AgentCode::close);
             }
 
             @Override
@@ -321,8 +321,8 @@ public void join() throws Exception {
             }
 
             @Override
-            public void close() throws Exception {
-                executeWithContextClassloader(AgentCode::close);
+            public void close() {
+                executeNoExceptionWithContextClassloader(AgentCode::close);
             }
 
             @Override

diff --git a/...ore/src/main/java/ai/langstream/runtime/impl/k8s/agents/PulsarDLQSourceAgentProvider.java b/...ore/src/main/java/ai/langstream/runtime/impl/k8s/agents/PulsarDLQSourceAgentProvider.java
@@ -56,8 +56,8 @@ public static class PulsarDLQSourceConfiguration {
         @ConfigProperty(
                 description =
                         """
-                        The URL of the Pulsar cluster to connect to.
-                        """,
+                                The URL of the Pulsar cluster to connect to.
+                                """,
                 defaultValue = "pulsar://localhost:6650",
                 required = false)
         @JsonProperty("pulsar-url")
@@ -66,8 +66,8 @@ public static class PulsarDLQSourceConfiguration {
         @ConfigProperty(
                 description =
                         """
-                        Namespace to listen for DLQ topics.
-                        """,
+                                Namespace to listen for DLQ topics.
+                                """,
                 defaultValue = "public/default",
                 required = false)
         @JsonProperty("namespace")
@@ -76,8 +76,8 @@ public static class PulsarDLQSourceConfiguration {
         @ConfigProperty(
                 description =
                         """
-                        Subscription name to use for the DLQ topics.
-                        """,
+                                Subscription name to use for the DLQ topics.
+                                """,
                 defaultValue = "langstream-dlq-subscription",
                 required = false)
         @JsonProperty("subscription")
@@ -86,8 +86,8 @@ public static class PulsarDLQSourceConfiguration {
         @ConfigProperty(
                 description =
                         """
-                        Suffix to use for DLQ topics.
-                        """,
+                                Suffix to use for DLQ topics.
+                                """,
                 defaultValue = "-DLQ",
                 required = false)
         @JsonProperty("dlq-suffix")
@@ -96,20 +96,29 @@ public static class PulsarDLQSourceConfiguration {
         @ConfigProperty(
                 description =
                         """
-                        Include partitioned topics in the DLQ topics.
-                        """,
+                                Include partitioned topics in the DLQ topics.
+                                """,
                 defaultValue = "false")
         @JsonProperty("include-partitioned")
         private boolean includePartitioned;
 
         @ConfigProperty(
                 description =
                         """
-                        Timeout in milliseconds to wait for messages from the DLQ topics.
-                        Default is 0, meaning it will wait indefinitely.
-                        """,
+                                Timeout in milliseconds to wait for messages from the DLQ topics.
+                                Default is 0, meaning it will wait indefinitely.
+                                """,
                 defaultValue = "0")
         @JsonProperty("timeout-ms")
         private int timeoutMs;
+
+        @ConfigProperty(
+                description =
+                        """
+                                Pattern auto discovery period in seconds.
+                                """,
+                defaultValue = "60")
+        @JsonProperty("pattern-auto-discovery-period-seconds")
+        private int autoDiscoveryPeriodSeconds;
     }
 }