in queue.go [184:199]
func (p *MNSQueue) BatchDeleteMessage(receiptHandles ...string) (resp BatchMessageDeleteErrorResponse, err error) {
if receiptHandles == nil || len(receiptHandles) == 0 {
return
}
handlers := ReceiptHandles{}
for _, handler := range receiptHandles {
handlers.ReceiptHandles = append(handlers.ReceiptHandles, handler)
}
p.qpsMonitor.checkQPS()
_, err = send(p.client, NewBatchOpDecoder(&resp), DELETE, nil, handlers, fmt.Sprintf("queues/%s/%s", p.name, "messages"), nil)
return
}