From 15bba6afe3c1db89bd1e075941829099fb2ece3b Mon Sep 17 00:00:00 2001
From: JianBo He <heeejianbo@163.com>
Date: Thu, 22 Jul 2021 22:20:22 +0800
Subject: [PATCH] fix(gw-exproto): fix start udp/dtls listener

---
 .../emqx_gateway/src/exproto/emqx_exproto_impl.erl | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl b/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl
index a7a827123..844df2b28 100644
--- a/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl
+++ b/apps/emqx_gateway/src/exproto/emqx_exproto_impl.erl
@@ -168,8 +168,18 @@ start_listener(InstaId, Ctx, Type, ListenOn, SocketOpts, Cfg) ->
              frame_mod => emqx_exproto_frame,
              chann_mod => emqx_exproto_channel
             },
-    esockd:open(Name, ListenOn, merge_default_by_type(Type, SocketOpts),
-                {emqx_gateway_conn, start_link, [NCfg]}).
+    MFA = {emqx_gateway_conn, start_link, [NCfg]},
+    NSockOpts = merge_default_by_type(Type, SocketOpts),
+    do_start_listener(Type, Name, ListenOn, NSockOpts, MFA).
+
+do_start_listener(Type, Name, ListenOn, Opts, MFA)
+  when Type == tcp;
+       Type == ssl ->
+    esockd:open(Name, ListenOn, Opts, MFA);
+do_start_listener(udp, Name, ListenOn, Opts, MFA) ->
+    esockd:open_udp(Name, ListenOn, Opts, MFA);
+do_start_listener(dtls, Name, ListenOn, Opts, MFA) ->
+    esockd:open_dtls(Name, ListenOn, Opts, MFA).
 
 name(InstaId, Type) ->
     list_to_atom(lists:concat([InstaId, ":", Type])).