(streampipes) branch dev updated: fix: broken mqtt data-cy in publisher (#3950)

[zehnder]

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

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new a7fd90c7c7 fix: broken mqtt data-cy in publisher (#3950)
a7fd90c7c7 is described below

commit a7fd90c7c7f7a4c26fcf8e15db420197f6d8808c
Author: Jacqueline Höllig <78690944+jhoe...@users.noreply.github.com>
AuthorDate: Fri Nov 21 09:20:21 2025 +0100

    fix: broken mqtt data-cy in publisher (#3950)
---
 .../streampipes/extensions/connectors/mqtt/shared/MqttPublisher.java | 2 +-
 ui/cypress/tests/thirdparty/Mqtt.spec.ts                             | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared/MqttPublisher.java
 
b/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared/MqttPublisher.java
index b3c8e2d0de..95ffdfbfcf 100644
--- 
a/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared/MqttPublisher.java
+++ 
b/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared/MqttPublisher.java
@@ -61,7 +61,7 @@ public class MqttPublisher extends MqttBase {
       this.conn.connect();
     } catch (Exception e) {
       throw new SpRuntimeException("Could not connect to MQTT broker: "
-          + uri.toString() + ", " + e.getMessage(), e);
+          + mqtt.getHost() + ", " + e.getMessage(), e);
     }
   }
 
diff --git a/ui/cypress/tests/thirdparty/Mqtt.spec.ts 
b/ui/cypress/tests/thirdparty/Mqtt.spec.ts
index fe5f50ef5e..8283e32d3b 100644
--- a/ui/cypress/tests/thirdparty/Mqtt.spec.ts
+++ b/ui/cypress/tests/thirdparty/Mqtt.spec.ts
@@ -30,14 +30,13 @@ describe('Test MQTT Integration', () => {
     it('Perform Test', () => {
         const topicName = 'cypresstopic';
         const host: string = ParameterUtils.get('localhost', 'mosquitto');
-        const port: string = ParameterUtils.get('1884', '1883');
+        const port: string = ParameterUtils.get('1883', '1883');
 
         const sink: PipelineElementInput = PipelineElementBuilder.create(
             'mqtt_publisher',
         )
-            .addInput('input', 'host', host)
+            .addInput('input', 'broker_url', 'tcp://' + host + ':' + port)
             .addInput('input', 'topic', topicName)
-            .addInput('input', 'port', port)
             .build();
 
         const adapter = AdapterBuilder.create('MQTT')