diff --git a/src/emqx_packet.erl b/src/emqx_packet.erl index 4b0912d3f..dc2c63cad 100644 --- a/src/emqx_packet.erl +++ b/src/emqx_packet.erl @@ -19,6 +19,10 @@ -include("emqx.hrl"). -include("emqx_mqtt.hrl"). +-export([ type/1 + , qos/1 + ]). + -export([ proto_name/1 , type_name/1 , validate/1 @@ -30,6 +34,12 @@ -compile(inline). +type(#mqtt_packet{header = #mqtt_packet_header{type = Type}}) -> + Type. + +qos(#mqtt_packet{header = #mqtt_packet_header{qos = QoS}}) -> + QoS. + %% @doc Protocol name of the version. -spec(proto_name(emqx_types:version()) -> binary()). proto_name(?MQTT_PROTO_V3) ->