anchor.diff:          {ok, ?ST_IDLING} ->
               ok;
           {ok,_Other} ->
  -            ?debugVal(_Other),
               check_state()
       end.
   
  
positive.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},
  
negative.code:     ?assertEqual(ok, Ret),
  
      ok = publish_messages(100),
      timer:sleep(timer:seconds(1)),
  
      ok = leo_mq_api:suspend(?QUEUE_ID_PUBLISHER),
  
      {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(),
  