trouble connecting hiveMQ clusterURL to my localhost ditto

[goko897]

I have created cluster in hiveMQ cloud console. I followed https://www.hivemq.com/blog/hands-on-guide-using-mqtt-hivemq-eclipse-ditto-digital-twins-iiot/#heading-hands-on-guide-to-using-mqtt-and-eclipse-ditto-for-digital-twins tutorial step by step bur now I want to connect my localhost ditto to cluster on hiveMQ.

My project involves Rpi connecting to hiveMQ as MQTT broker which then is directed to ditto. BUt when I run the code below

{
  "id": "e703fc5d-ee69-4ebe-a498-1b3adcfbdd44",
  "name": "HiveMQ",
  "connectionType": "mqtt-5",
  "connectionStatus": "open",
  "uri": "ssl://{username}:{password}1422667859c0481aa616b788e8212f69.s1.eu.hivemq.cloud:8883",
  "sources": [
    {
      "addresses": [
        "devices/+"
      ],
      "consumerCount": 1,
      "qos": 1,
      "authorizationContext": [
        "connection:hivemq-mqtt"
      ],
      "enforcement": {
        "input": "{{ source:address }}",
        "filters": [
          "devices/{{ thing:id }}"
        ]
      },
      "headerMapping": {
        "reply-to": "{{header:reply-to}}",
        "content-type": "{{header:content-type}}",
        "correlation-id": "{{header:correlation-id}}"
      },
      "payloadMapping": [
        "javascript"
      ],
      "replyTarget": {
        "address": "{{header:reply-to}}",
        "headerMapping": {
          "content-type": "{{header:content-type}}",
          "correlation-id": "{{header:correlation-id}}"
        },
        "expectedResponseTypes": [
          "response",
          "error"
        ],
        "enabled": true
      }
    }
  ],
  "targets": [
    {
      "address": "devices/{{ thing:id }}/downlink",
      "topics": [
        "_/_/things/twin/events"
      ],
      "qos": 1,
      "authorizationContext": [
        "connection:hivemq-mqtt"
      ],
      "headerMapping": {
        "reply-to": "devices/{{ thing:name }}/downlink",
        "correlation-id": "{{ header:correlation-id }}",
        "Content-Type": "application/vnd.eclipse.ditto+json"
      },
      "payloadMapping": [
        "Ditto"
      ]
    }
  ],
  "clientCount": 1,
  "failoverEnabled": true,
  "validateCertificates": true,
  "processorPoolSize": 1,
  "mappingDefinitions": {
    "javascript": {
      "mappingEngine": "JavaScript",
      "options": {
        "incomingScript": "function mapToDittoProtocolMsg(headers, textPayload, bytePayload, contentType) {\r\n    const jsonString = String.fromCharCode.apply(null, new Uint8Array(bytePayload));\r\n    const jsonData = JSON.parse(jsonString); \r\n    const thingId = jsonData.thingId.split(':'); \r\n    const value = { \r\n        temp_sensor: { \r\n            properties: { \r\n                value: jsonData.temp \r\n            } \r\n        },\r\n        gaz_sensor: { \r\n            properties: { \r\n                value: jsonData.gaz \r\n            } \r\n        }, \r\n\t\t\t\talert_led: { \r\n            properties: { \r\n                value: jsonData.alert \r\n            } \r\n        },   \r\n    };    \r\n    return Ditto.buildDittoProtocolMsg(\r\n        thingId[0], // your namespace \r\n        thingId[1], \r\n        'things', // we deal with a thing\r\n        'twin', // we want to update the twin\r\n        'commands', // create a command to update the twin\r\n        'modify', // modify the twin\r\n        '/features', // modify all features at once\r\n        headers, \r\n        value\r\n    );\r\n}\r\n",
        "outgoingScript": ""
      }
    }
  },
  "tags": []
}

it gives me 502 bad gateway for cluster url

please help me resolve this

[thjaeckle]

Hi @goko897
This URI looks wrong:

"uri": "ssl://{username}:{password}1422667859c0481aa616b788e8212f69.s1.eu.hivemq.cloud:8883",

The @ delimiter between {username}:{password} and the hostname is missing.
Could you check if this was just a copy&paste error or if it really is missing?

[goko897]

I missed that @ delimiter