anchor.diff:        pid_to_topics = ets:new(list_to_atom(?TABLE_PREFIX ++ "pid_to_topics"), [bag]),
         topic_to_pids = ets:new(list_to_atom(?TABLE_PREFIX ++ "topic_to_pids"), [bag]),
         serial_number = 0,
  +      oldest_stored_serial = 0,
         %% Bounded queue for keeping track of what we stick into the per_topic_message_queue
         %% This is used for bookeeping for evicting things from the per_topic_message_queue
         %% [{Topics[], Serial#}, ...]
  
positive.code:   {reply, TopicStatus, State};
  
  handle_call({get_buffered_msgs, WaitressShardHorizon, ShardTopics}, _From,
              State=#state{eviction_queue=EvictionQueue,
                           per_topic_message_queue=QueueMap}) ->
    QueuePeek = bounded_queue:peek(EvictionQueue),
    {_Topics, OldestMessageSerial} = (if (QueuePeek == empty) -> {[], 0};
          true -> QueuePeek end),
      %% Invalid Case
      if (OldestMessageSerial > WaitressShardHorizon) ->
          {reply, failure, State};
        true ->
          {reply, 
  
negative.code:   {noreply, State#state{
        serial_number=NextSerial, 
        eviction_queue=NextEvictionQueue,
        oldest_stored_serial=NextOldestStoredSerial,
        per_topic_message_queue=NextMQueueMap}};
  
  % Cast is ok for register because it's ok if we are not notified immediatly
  