anchor.diff:           ([#mqtt_pingreq{}]) -> ok;
            ([#mqtt_pingresp{}]) -> ok;
            ([#mqtt_disconnect{}]) -> ok end).
  +
  +vmq_m5_parser_serialize_ms() ->
  +    dbg:fun2ms(
  +      fun([#mqtt5_connect{}]) -> ok;
  +         ([#mqtt5_connack{}]) -> ok;
  +         ([#mqtt5_publish{}]) -> ok;
  +         ([#mqtt5_puback{}]) -> ok;
  +         ([#mqtt5_pubrec{}]) -> ok;
  +         ([#mqtt5_pubrel{}]) -> ok;
  +         ([#mqtt5_pubcomp{}]) -> ok;
  +         ([#mqtt5_subscribe{}]) -> ok;
  +         ([#mqtt5_unsubscribe{}]) -> ok;
  +         ([#mqtt5_suback{}]) -> ok;
  +         ([#mqtt5_unsuback{}]) -> ok;
  +         ([#mqtt5_pingreq{}]) -> ok;
  +         ([#mqtt5_pingresp{}]) -> ok;
  +         ([#mqtt5_disconnect{}]) -> ok;
  +         ([#mqtt5_auth{}]) -> ok end).
   
   vmq_mqtt_fsm_connected_ms() ->
       dbg:fun2ms(
  
positive.code:     Opts = #{payload_limit => PayloadLimit},
      SId = {"", ClientId},
      io:format(IoServer, "New session with PID ~p found for client \"~s\"~n", [SessionPid, ClientId]),
      {F, D} = prepf(format_mqtt(to, SessionPid, SId, ConnFrame, Opts)),
      io:format(IoServer, F, D),
      NewState = begin_session_trace([SessionPid], State),
      {reply, ok, NewState};
  
negative.code: -module(vmq_tracer).
  -include_lib("stdlib/include/ms_transform.hrl").
  -include_lib("vmq_commons/include/vmq_types.hrl").
  -include_lib("vmq_commons/include/vmq_types_mqtt5.hrl").
  
  -behaviour(gen_server).
  
  