anchor.diff:      %% launch queue-processes
       MaxInterval  = leo_misc:get_value(cns_interval_fail_rebalance_max,
                                         Intervals, ?DEF_CONSUME_MAX_INTERVAL),
  -    MinInterval  = leo_misc:get_value(cns_interval_fail_rebalance_min,
  -                                      Intervals, ?DEF_CONSUME_MIN_INTERVAL),
       RegInterval  = leo_misc:get_value(cns_interval_fail_rebalance_regular,
                                         Intervals, ?DEF_CONSUME_REG_INTERVAL),
  -    StepInterval = leo_misc:get_value(cns_interval_fail_rebalance_step,
  -                                      Intervals, ?DEF_CONSUME_STEP_INTERVAL),
       RootPath_1 = case (string:len(RootPath) == string:rstr(RootPath, ?SLASH)) of
                        true  -> RootPath;
                        false -> RootPath ++ ?SLASH
  
positive.code:                     {?MQ_PROP_DB_NAME,   ?env_mq_backend_db()},
                      {?MQ_PROP_DB_PROCS,  ?env_num_of_mq_procs()},
                      {?MQ_PROP_INTERVAL_MAX,    MaxInterval},
                      {?MQ_PROP_INTERVAL_MIN,    MinInterval},
                      {?MQ_PROP_INTERVAL_REG,    RegInterval},
                      {?MQ_PROP_INTERVAL_STEP,   StepInterval},
                      {?MQ_PROP_BATCH_MSGS_MAX,  ?DEF_CONSUME_MAX_BATCH_MSGS},
                      {?MQ_PROP_BATCH_MSGS_MIN,  ?DEF_CONSUME_MIN_BATCH_MSGS},
                      {?MQ_PROP_BATCH_MSGS_REG,  ?DEF_CONSUME_REG_BATCH_MSGS},
                      {?MQ_PROP_BATCH_MSGS_STEP, ?DEF_CONSUME_STEP_BATCH_MSGS}
                     ]),
      ok.
  
  
negative.code: -define(SLASH, "/").
  -define(MQ_MSG_PATH_REBALANCE, "1").
  -define(DEF_MQ_PROP_MAX_INTERVAL, 15000).
  
  -define(env_num_of_mq_procs(),
          case application:get_env(leo_manager, num_of_mq_procs) of
  