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:                 _ -> AccIn
              end
      end.
  
  
  handle_pull(WSize,ClientId,S = #state{filter = Filter,
                                        live_subs = Subs,
  
negative.code:     Subs1 = dict:update(ClientId,Fun,Subs),
      S#state{live_subs = Subs1}.
  
  handle_ack(ClientId,{q,QAck},S = #state{queue = Q,
                                          garbage = Garbage}) ->
      {MoreGarbage,Q1} = shared_queue:forward(ClientId,QAck,Q),
      S#state{queue = Q1,garbage = ?MONOID:as(Garbage,MoreGarbage)}.
  
  maybe_store_retained(#packet{retain = false},_Seq,Ret)               -> Ret;
  maybe_store_retained(#packet{topic = Topic,content = <<>>},Seq,Ret)  -> shared_set:remove(Topic,Seq,Ret);
  maybe_store_retained(Packet = #packet{topic = Topic},Seq,Ret)        -> shared_set:append(Topic,Packet,Seq,Ret).
  
  %% ===================================================================
  %% Packet Sending
  