diff --git a/src/emqx_connection.erl b/src/emqx_connection.erl
index 222e2bb3f..868ef1deb 100644
--- a/src/emqx_connection.erl
+++ b/src/emqx_connection.erl
@@ -135,7 +135,7 @@ init([Transport, RawSocket, Options]) ->
             ProtoState = emqx_protocol:init(#{peername => Peername,
                                               sockname => Sockname,
                                               peercert => Peercert,
-                                              sendfun  => SendFun}, [Options ++ [{socktype, SockType}]]),
+                                              sendfun  => SendFun}, Options ++ [{socktype, SockType}]),
             ParserState = emqx_protocol:parser(ProtoState),
             GcPolicy = emqx_zone:get_env(Zone, force_gc_policy, false),
             GcState = emqx_gc:init(GcPolicy),
diff --git a/src/emqx_ws_connection.erl b/src/emqx_ws_connection.erl
index 10da543e0..6cd0b701d 100644
--- a/src/emqx_ws_connection.erl
+++ b/src/emqx_ws_connection.erl
@@ -126,7 +126,7 @@ websocket_init(#state{request = Req, options = Options}) ->
     ProtoState = emqx_protocol:init(#{peername => Peername,
                                       sockname => Sockname,
                                       peercert => Peercert,
-                                      sendfun  => send_fun(self())}, [Options ++ [{socktype, websocket}]]),
+                                      sendfun  => send_fun(self())}, Options ++ [{socktype, websocket}]),
     ParserState = emqx_protocol:parser(ProtoState),
     Zone = proplists:get_value(zone, Options),
     EnableStats = emqx_zone:get_env(Zone, enable_stats, true),