Skip to content

Commit 1f5ece3

Browse files
committed
MQTT over websocket is no longer supported
gmqtt does not support websocket atm
1 parent 8b513ca commit 1f5ece3

File tree

4 files changed

+1
-5
lines changed

4 files changed

+1
-5
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ The following are the known available endpoints:
4646

4747
| CMD param | ENV variable | Description |
4848
|-----------------------------------|---------------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
49-
| -m or --mqtt-uri | MQTT_URI | URI to the MQTT Server. TCP: tcp://mqtt.eclipseprojects.io:1883, WebSocket: ws://mqtt.eclipseprojects.io:9001 or TLS: tls://mqtt.eclipseprojects.io:8883 - Leave it empty to disable MQTT connection |
49+
| -m or --mqtt-uri | MQTT_URI | URI to the MQTT Server. TCP: tcp://mqtt.eclipseprojects.io:1883 or TLS: tls://mqtt.eclipseprojects.io:8883 - Leave it empty to disable MQTT connection |
5050
| --mqtt-server-cert | MQTT_SERVER_CERT | Path to the server certificate authority file in PEM format is required for TLS |
5151
| --mqtt-server-cert-check-hostname | MQTT_SERVER_CERT_CHECK_HOSTNAME | Enable or disable TLS certificate hostname checking when using a custom certificate. Enabled (True) by default. Set to False when using a self-signed certificate without a matching hostname. This option might be insecure. |
5252
| --mqtt-user | MQTT_USER | MQTT user name |

src/configuration/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@ def __init__(self, transport_mechanism: str, with_tls: bool) -> None:
1313
self.with_tls = with_tls
1414

1515
TCP = "tcp", False
16-
WS = "websockets", False
1716
TLS = "tcp", True
1817

1918

src/configuration/parser.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,6 @@ def __parse_mqtt_transport(args: Namespace, config: Configuration) -> None:
9292
parse_result = urllib.parse.urlparse(args.mqtt_uri)
9393
if parse_result.scheme == "tcp":
9494
config.mqtt_transport_protocol = TransportProtocol.TCP
95-
elif parse_result.scheme == "ws":
96-
config.mqtt_transport_protocol = TransportProtocol.WS
9795
elif parse_result.scheme == "tls":
9896
config.mqtt_transport_protocol = TransportProtocol.TLS
9997
if args.tls_server_cert_path:

src/publisher/mqtt_publisher.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ def __init__(self, configuration: Configuration) -> None:
3030

3131
mqtt_client = gmqtt.Client(
3232
client_id=str(self.publisher_id),
33-
transport=self.transport_protocol.transport_mechanism,
3433
will_message=gmqtt.Message(
3534
topic=self.get_topic(mqtt_topics.INTERNAL_LWT, False),
3635
payload="offline",

0 commit comments

Comments
 (0)