anchor.diff:                  Error
           end, {ok, State, []}, re:split(TopicString, ", +", [{return, list}, {parts, 2}])),
       case RetVal of
  -        ok -> {reply, RetVal, NewState#state{ 
  -                    watch_dict = dict:store(WatchId, 
  -                        #watch{ 
  -                            watch_list = WatchList, 
  -                            callback = CallBack, 
  -                            user_info = UserInfo, 
  -                            exp_time = ExpTime, 
  +        ok -> {reply, RetVal, NewState#state{
  +                    watch_dict = dict:store(WatchId,
  +                        #watch{
  +                            watch_list = WatchList,
  +                            callback = CallBack,
  +                            user_info = UserInfo,
  +                            exp_time = ExpTime,
                               ttl = TTL}, NewState#state.watch_dict),
                       ttl_tree = tiny_pq:insert_value(ExpTime, WatchId, NewState#state.ttl_tree)
                   }};
  
positive.code: 
      OldRecord           = activate_record(Id, OldAttrs),
      OldAttributes       = OldRecord:attributes(),
      
      NewRecord           = activate_record(Id, NewAttrs),
      NewAttributes       = NewRecord:attributes(),
  
  
negative.code:                                     }, {id_attr, Id, Attr}}
                          end,
                          {ok, NewState1, [WatchInfo|WatchListAcc]};
                      _ ->
                          case re:split(SingleTopic, "-", [{return, list}, {parts, 2}]) of
                              [_Module, _IdNum] ->
                                  IdWatchers = case dict:find(SingleTopic, State#state.id_watchers) of
  