rabbitmq_peek_messages
Diagnose RabbitMQ queue backlogs by sampling messages at the head without consuming them. Messages are requeued after reading to prevent data loss and duplicate reads.
Instructions
对队列头部消息实施无损诊断采样 (Peek).
读取消息后延迟在循环结束后统一触发 reject(requeue=True),确保数据零丢失且不出队,同时防止重复读取同一条消息 (ADR-0002)。
@param queue 目标队列名称 @param count 采样数量限制(1-50,默认 10) @param connection 目标连接别名,默认为 'default' @return 采样消息清单报告
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| count | No | ||
| queue | Yes | ||
| connection | No | default |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||