anchor.diff:  mq_stats([]) ->
       [];
   mq_stats(Stats) ->
  -    Header = "              id                |    state    | num of msgs |            description            \r\n"
  -        ++   "--------------------------------+-------------+-------------|-----------------------------------\r\n",
  +    Header = "              id                |    state    | number of msgs | batch of msgs  |    interval    |            description            \r\n"
  +        ++   "--------------------------------+-------------+----------------|----------------|----------------|-----------------------------------\r\n",
       Output = lists:foldl(
                  fun(#mq_state{id = Id,
  -                             state = State,
  -                             num_of_messages = NumOfMsgs,
  +                             state = ConsumerStats,
                                desc = Desc}, Acc) ->
  +                       State       = leo_misc:get_value(?MQ_CNS_PROP_STATUS,        ConsumerStats),
  +                       NumOfMsgs   = leo_misc:get_value(?MQ_CNS_PROP_NUM_OF_MSGS,   ConsumerStats, 0),
  +                       BatchOfMsgs = leo_misc:get_value(?MQ_CNS_PROP_BATCH_OF_MSGS, ConsumerStats, 0),
  +                       Interval    = leo_misc:get_value(?MQ_CNS_PROP_INTERVAL,      ConsumerStats, 0),
                          lists:append([Acc,
  -                                     string:left(" " ++ atom_to_list(Id),    31), ?SEPARATOR,
  -                                     string:centre(atom_to_list(State),      11), ?SEPARATOR,
  -                                     string:left(integer_to_list(NumOfMsgs), 11), ?SEPARATOR,
  +                                     string:left(" " ++ atom_to_list(Id),      31), ?SEPARATOR,
  +                                     string:centre(atom_to_list(State),        11), ?SEPARATOR,
  +                                     string:left(integer_to_list(NumOfMsgs),   14), ?SEPARATOR,
  +                                     string:left(integer_to_list(BatchOfMsgs), 14), ?SEPARATOR,
  +                                     string:left(integer_to_list(Interval),    14), ?SEPARATOR,
                                        string:left(Desc, 34), ?CRLF])
                  end, Header, Stats),
       Output.
  
positive.code:                                 "                          kernel_poll | ~w\r\n",
                                  "                     thread_pool_size | ~w\r\n",
                                  "--------------------------------------+--------------------------------------\r\n",
                                  " Status-3: # of msgs\r\n",
                                  "--------------------------------------+--------------------------------------\r\n",
                                  "                     replication msgs | ~w\r\n",
                                  "                      vnode-sync msgs | ~w\r\n",
                                  "                       rebalance msgs | ~w\r\n",
                                  "--------------------------------------+--------------------------------------\r\n",
                                  "\r\n"]),
                    [
  
negative.code:                                 "-------------------------------+------------------\r\n",
                                  "                listening port | ~w\r\n",
                                  "            listening ssl port | ~w\r\n",
                                  "           number of_acceptors | ~w\r\n",
                                  "-------------------------------+------------------\r\n",
                                  " [cache-related]\r\n",
                                  "-------------------------------+------------------\r\n",
                                  "       http cache [true|false] | ~w\r\n",
                                  "       number of cache_workers | ~w\r\n",
                                  "                  cache expire | ~w\r\n",
                                  "         cache max content len | ~w\r\n",
                                  "            ram cache capacity | ~w\r\n",
  