anchor.diff:      ?assertEqual(ok, Ret),
   
       ok = publish_messages(100),
  -    timer:sleep(1000),
  -
  -    ?debugVal("===== suspend ====="),
  +    timer:sleep(timer:seconds(1)),
  +
       ok = leo_mq_api:suspend(?QUEUE_ID_PUBLISHER),
  -    timer:sleep(5000),
  -    ?debugVal("===== resume ====="),
  +
  +    {ok, TotalMsgs} = leo_mq_api:status(?QUEUE_ID_PUBLISHER),
  +    ?assertEqual(true, TotalMsgs > 0),
  +
  +    timer:sleep(timer:seconds(3)),
       ok = leo_mq_api:resume(?QUEUE_ID_PUBLISHER),
   
       ok = check_state(),
  
positive.code:         {ok, ?ST_IDLING} ->
              ok;
          {ok,_Other} ->
              ?debugVal(_Other),
              check_state()
      end.
  
  
negative.code:                             _ ->
                                  throw({error, invalid_message})
                          end;
                     ({publish, Id, Reply}) ->
                          ?debugVal({publish, Id, Reply}),
                          ok
                  end),
      Ret =  leo_mq_api:new(?QUEUE_ID_PUBLISHER, [{module, ?TEST_CLIENT_MOD},
  