diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl index 93a1a8b64..3638e94e2 100644 --- a/src/emqx_protocol.erl +++ b/src/emqx_protocol.erl @@ -562,6 +562,9 @@ send(Packet = ?PACKET(Type), PState = #pstate{proto_ver = Ver, sendfun = SendFun {binary, _Data} -> emqx_metrics:sent(Packet), {ok, inc_stats(send, Type, PState)}; + {datagram, _Peer, _Data} -> + emqx_metrics:sent(Packet), + {ok, inc_stats(send, Type, PState)}; {error, Reason} -> {error, Reason} end.