anchor.diff:                                                key = Key,
                                                 node = Node,
                                                 timestamp = leo_date:now()}),
  -            Table = ?TBL_REBALANCE_COUNTER,
  -            case ets_lookup(Table, VNodeId) of
  -                {ok, 0} ->
  -                    ets:insert(Table, {VNodeId, 0});
  -                _Other ->
  -                    void
  -            end,
  -            ok = increment_counter(Table, VNodeId),
               leo_mq_api:publish(Id, KeyBin, MessageBin)
       end;
   
  
positive.code:             {error, ?ERROR_COULD_NOT_GET_META}
      end.
  
  
  %%--------------------------------------------------------------------
  %% INNTERNAL FUNCTIONS-2 ETS related functions
  %%--------------------------------------------------------------------
  %% @doc Lookup rebalance counter
  %% @private
  -spec(ets_lookup(Table, Key) ->
               {ok, Value} | {error, Cause} when Table::atom(),
                                                 Key::binary(),
                                                 Value::integer(),
                                                 Cause::any()).
  ets_lookup(Table, Key) ->
      case catch ets:lookup(Table, Key) of
          [] ->
              {ok, 0};
          [{_Key, Value}] ->
              {ok, Value};
          {'EXIT', Cause} ->
              {error, Cause}
      end.
  
  
  %% @doc Increment rebalance counter
  %% @private
  -spec(increment_counter(Table, Key) ->
               ok when Table::atom(),
                       Key::binary()).
  increment_counter(Table, Key) ->
      catch ets:update_counter(Table, Key, 1),
      ok.
  
  %% @doc Decrement rebalance counter
  %% @private
  -spec(decrement_counter(Table, Key) ->
               ok when Table::atom(),
                       Key::binary()).
  decrement_counter(Table, Key) ->
      catch ets:update_counter(Table, Key, -1),
      ok.
  
negative.code:                                key = Key} = Msg) ->
      case leo_redundant_manager_api:get_member_by_node(Node) of
          {ok, #member{state = ?STATE_RUNNING}} ->
  
              case leo_redundant_manager_api:get_redundancies_by_key(Key) of
                  {ok, #redundancies{nodes = Redundancies}} ->
  