(streampipes) branch 3927-migrate-all-data-sinks-from-streampipesdatasink-to-istreampipesdatasink updated: refactor(#3927): Update data sink implementations to use new configuration interface

[zehnder]

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

zehnder pushed a commit to branch 
3927-migrate-all-data-sinks-from-streampipesdatasink-to-istreampipesdatasink
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/3927-migrate-all-data-sinks-from-streampipesdatasink-to-istreampipesdatasink
 by this push:
     new f3d2cbec2d refactor(#3927): Update data sink implementations to use 
new configuration interface
f3d2cbec2d is described below

commit f3d2cbec2dae2b1af787ab3efd3f4b4b51c3eae6
Author: Philipp Zehnder <ten...@users.noreply.github.com>
AuthorDate: Fri Nov 14 08:30:46 2025 +0100

    refactor(#3927): Update data sink implementations to use new configuration 
interface
---
 .../notifications/jvm/msteams/MSTeamsSink.java     | 25 ++++++++++++++++------
 1 file changed, 19 insertions(+), 6 deletions(-)

diff --git 
a/streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/msteams/MSTeamsSink.java
 
b/streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/msteams/MSTeamsSink.java
index 555a2c5d71..4f03b1c6df 100644
--- 
a/streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/msteams/MSTeamsSink.java
+++ 
b/streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/msteams/MSTeamsSink.java
@@ -19,7 +19,9 @@
 package org.apache.streampipes.sinks.notifications.jvm.msteams;
 
 import org.apache.streampipes.commons.exceptions.SpRuntimeException;
+import org.apache.streampipes.extensions.api.pe.config.IDataSinkConfiguration;
 import 
org.apache.streampipes.extensions.api.pe.context.EventSinkRuntimeContext;
+import org.apache.streampipes.extensions.api.pe.param.IDataSinkParameters;
 import org.apache.streampipes.model.DataSinkType;
 import org.apache.streampipes.model.extensions.ExtensionAssetType;
 import org.apache.streampipes.model.runtime.Event;
@@ -27,11 +29,11 @@ import 
org.apache.streampipes.pe.shared.PlaceholderExtractor;
 import org.apache.streampipes.sdk.StaticProperties;
 import org.apache.streampipes.sdk.builder.DataSinkBuilder;
 import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder;
+import org.apache.streampipes.sdk.builder.sink.DataSinkConfiguration;
 import org.apache.streampipes.sdk.helpers.Alternatives;
 import org.apache.streampipes.sdk.helpers.EpRequirements;
 import org.apache.streampipes.sdk.helpers.Labels;
 import org.apache.streampipes.sdk.helpers.Locales;
-import org.apache.streampipes.wrapper.params.compat.SinkParams;
 import org.apache.streampipes.wrapper.standalone.StreamPipesNotificationSink;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
@@ -78,11 +80,22 @@ public class MSTeamsSink extends 
StreamPipesNotificationSink {
   }
 
   @Override
-  public void onInvocation(
-      SinkParams parameters,
+  public IDataSinkConfiguration declareConfig() {
+    var builder = declareModelWithoutSilentPeriod();
+    addSilentPeriodParameter(builder);
+
+    return DataSinkConfiguration.create(
+        MSTeamsSink::new,
+        builder.build()
+    );
+  }
+
+  @Override
+  public void onPipelineStarted(
+      IDataSinkParameters parameters,
       EventSinkRuntimeContext runtimeContext
-  ) throws SpRuntimeException {
-    super.onInvocation(parameters, runtimeContext);
+  ) {
+    super.onPipelineStarted(parameters, runtimeContext);
 
     this.objectMapper = new ObjectMapper();
 
@@ -173,7 +186,7 @@ public class MSTeamsSink extends 
StreamPipesNotificationSink {
   }
 
   @Override
-  public void onDetach() {
+  public void onPipelineStopped() {
     // nothing to do
   }