You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2026/01/29 13:53:50 UTC

(streampipes) 02/03: fix(#4137): Remove unused method

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

zehnder pushed a commit to branch 4137-updating-mqtt-adapter-can-leave-orphaned-consumer-thread
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit bbc91d1da861f402669a82cc4ea3741aa3cbc3c3
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Thu Jan 29 13:58:14 2026 +0100

    fix(#4137): Remove unused method
---
 .../apache/streampipes/integration/adapters/MQTTPublisherUtils.java  | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MQTTPublisherUtils.java b/streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MQTTPublisherUtils.java
index 87ce58e814..c273982f09 100644
--- a/streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MQTTPublisherUtils.java
+++ b/streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MQTTPublisherUtils.java
@@ -57,9 +57,4 @@ public class MQTTPublisherUtils {
         publisher.connect();
         return publisher;
     }
-
-    public static void closeConnection(MqttPublisher publisher) {
-        publisher.disconnect();
-    }
-
 }