anchor.diff:      {ok,#state{filter = Filter,
                  monref_idx = dict:new(),
                  live_subs = dict:new(),
  -               dead_subs = dict:new(),
                  packet_seq = Seq,
                  queue = shared_queue:new(Seq),
  -               retained = shared_set:new(),
  -               repo = Repo}}.
  +               retained = shared_set:new()}}.
   
   %%--------------------------------------------------------------------
   %% @private
  
positive.code: -type dict()::any().
  
  -record(state, {
      repo            ::module(), %% Module used for persistence
      filter          ::binary(), %% Filter handled by this process (e.g. /A/B/+
      live_subs       ::dict(),    %% dictionary of {ClientId::binary(),#client_reg{}}
      dead_subs       ::dict(),
      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
      queue           ::any(),    %% Shared queue of messages
      retained        ::shared_set:shared_set(),   %% Dictionary of retained messages
      garbage         ::any()     %% garbage stats from the queue
  
negative.code: send_packet(CPid,Filter,P) -> mqtt_session_out:push(CPid,Filter,P).
  
  %% ===================================================================
  %% Managing Subscriptions
  %% ===================================================================
  
  set_sub({ClientId,ClientSeq,QoS,Pid},NextInQ,WSize,S = #state{monref_idx = Mons,
  