From c1506a731c7a7ecdf0d1c1cc9ad90621ae643f5b Mon Sep 17 00:00:00 2001 From: wanghaemq Date: Thu, 23 May 2024 06:03:40 -0400 Subject: [PATCH] * NEW [stream] Add nmq-tls mqtt-tls scheme. Signed-off-by: wanghaemq --- src/core/stream.c | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/src/core/stream.c b/src/core/stream.c index 1059cf813..baedd9479 100644 --- a/src/core/stream.c +++ b/src/core/stream.c @@ -80,6 +80,21 @@ static struct { .dialer_alloc = nni_tls_dialer_alloc, .listener_alloc = nni_tls_listener_alloc, }, + { + .scheme = "mqtt-tls", + .dialer_alloc = nni_tls_dialer_alloc, + .listener_alloc = nni_tls_listener_alloc, + }, + { + .scheme = "mqtt-tls4", + .dialer_alloc = nni_tls_dialer_alloc, + .listener_alloc = nni_tls_listener_alloc, + }, + { + .scheme = "mqtt-tls6", + .dialer_alloc = nni_tls_dialer_alloc, + .listener_alloc = nni_tls_listener_alloc, + }, { .scheme = "tcp", .dialer_alloc = nni_tcp_dialer_alloc, @@ -159,6 +174,21 @@ static struct { .dialer_alloc = nni_tls_dialer_alloc, .listener_alloc = nni_tls_listener_alloc, }, + { + .scheme = "nmq-tls", + .dialer_alloc = nni_tls_dialer_alloc, + .listener_alloc = nni_tls_listener_alloc, + }, + { + .scheme = "nmq-tls4", + .dialer_alloc = nni_tls_dialer_alloc, + .listener_alloc = nni_tls_listener_alloc, + }, + { + .scheme = "nmq-tls6", + .dialer_alloc = nni_tls_dialer_alloc, + .listener_alloc = nni_tls_listener_alloc, + }, { .scheme = "ws", .dialer_alloc = nni_ws_dialer_alloc,