anchor.diff:      S1 = S#state{live_subs = Subs1,
                    queue = SQ1,
                    retained = Ret1},
  -    MQPacket = Packet#packet{retain = false, ref = {q,NewSeq}},
  +    MQPacket = Packet#packet{retain = false,ref = {q,NewSeq}},
       send_packet_to_clients(SendTo,Filter,MQPacket),
       {reply,{ok, NewSeq},S1}.
   
  
positive.code: send_packet(CPid,Filter,P) -> mqtt_session_out:push(CPid,Filter,P).
  
  %% ===================================================================
  %% Subscriptions
  %% ===================================================================
  
  set_sub({ClientId,ClientSeq,QoS,Pid},NextInQ,WSize,S = #state{monref_idx = Mons,
  
negative.code: -type dict()::any().
  
  -record(state, {
      filter          ::binary(), %% Filter handled by this process (e.g. /A/B/+
      live_subs       ::dict(),    %% dictionary of {ClientId::binary(),#client_reg{}}
      monref_idx      ::any(),    %% dictionary of (MonitorRef,ClientId}
      packet_seq      ::non_neg_integer(),%% A sequence number assigned to each Message from a topic covered by this filter.
                                      %% This process assigns incremental integers to each new message
      client_seqs     ::any(),
      queue           ::any(),    %% Shared queue of messages
      retained        ::shared_set:shared_set(),   %% Dictionary of retained messages
      garbage         ::any()     %% garbage stats from the queue
  