anchor.diff:                      self() ! loop
               end,
               {noreply, NewState#state{shaper=NewShaper}};
  -        {retry, Reason} ->
  -            ?ERROR_MSG("Retry with reason:~p", [Reason]),
  -            erlang:send_after(1000, self(), loop),
  -            {noreply, State};
  +        {retry, State1, User, Reason} ->
  +            ?ERROR_MSG("Retry with reason:~p,user=~p", [Reason, User]),
  +            self() ! {retry, User},
  +            {noreply, State1};
           Other ->
               ?INFO_MSG("Stop with:state=~p, skip_cnt=~p, transfer_cnt=~p, res=~p",
                         [State, State#state.skip_cnt, State#state.transfer_cnt, Other]),
  
positive.code:             application:set_env(message_store, {?MODULE, run_state}, [R||R<-tuple_to_list(State), is_integer(R) orelse is_list(R)]),
              {stop, normal, State}
      end;
  handle_info(_Info, State) ->
      {noreply, State}.
  
  
negative.code:         [] ->
              false;
          {error, Reason} ->
              throw({dets_fail, User, Reason})
      end.
  
  set_old_user(User) ->
  