对于从未接收过的消息,可以直接调用这两个接口删掉消息,与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
- successful : list< string > 删除成功的消息ID列表
- failed : list< MessageBatchErrorEntry > 删除失败的消息异常信息