对于从未接收过的消息,可以直接调用这两个接口删掉消息,与deleteMessage不同的是, 这里的删掉无需先接收消息,并且会直接将EMQ底层对消息的存储删掉,后续便不可再使用任何方法消费消息.

deletePeekMessage()


方法参数DeletePeekMessageRequest

queueName : String : required
receiptHandle : String : required

发送消息成功后获取的消息ID, 仅可删除从未接收过的消息.

方法无返回

deletePeekMessageBatch()


方法参数DeletePeekMessageBatchRequest

queueName : String : required
deletePeekMessageBatchEntryList : list< DeletePeekMessageBatchEntry > : required

DeletePeekMessageBatchEntry包含的字段有: receiptHandle : String : required 发送消息成功后获取的消息ID, 仅可删除从未接收过的消息.

方法返回DeletePeekMessageBatchResponse

  1. successful : list< string > 删除成功的消息ID列表
  2. failed : list< MessageBatchErrorEntry > 删除失败的消息异常信息

results matching ""

    No results matching ""