You need to enable JavaScript to run this app.
导航
消息队列 RocketMQ版
  • 文档首页
    • /
  • 消息队列 RocketMQ版

QueryDLQMessageByMessageId

最近更新时间：2024.03.06 16:49:21

首次发布时间：2022.04.20 19:35:25

我的收藏

调用 QueryDLQMessageByMessageId 接口根据 Message ID 查询死信队列中的指定死信消息。

注意事项

请求频率：该接口请求频率限制为 100 次/秒；单用户请求频率限制为 20 次/秒。

请求参数

参数

参数类型

是否必选

示例值

说明

Group

String

必选

GID-123123

死信消息所在的 Group ID。

MessageId

String

必选

7D****

消息 ID，即 Message ID。

NeedMessageBody

Bool

必选

false

是否需要返回消息体。

  • true：返回消息体。
  • false：不返回消息体。

InstanceId

String

必选

MQ_INST_*******

死信消息所在的实例 ID。

响应参数

参数

参数类型

说明

Total

Integer

消息总数。

Messages

List

消息列表。消息信息请参考 Message。

msgNotExist

Bool

消息是否仍旧保存在服务端。

  • true：因超出服务端保存时长，此消息已被删除。
  • false：消息仍旧保存在服务端。

shouldRetryQuery

Bool

是否需要重试查询。

  • true：重试。
  • false：不重试。

BatchMsgNotExist

Map<String,Bool>

查询多个消息时，这些消息是否仍旧保存在服务端。

  • true：因超出服务端保存时长，此消息已被删除。
  • false：消息仍旧保存在服务端。

BatchMsgShouldRetryQuery

Map<String,Bool>

查询多个消息时，这些消息是否需要重试查询。

  • true：重试。
  • false：不重试。

示例

请求示例

POST https://rocketmq.volcengineapi.com/?Action=QueryDLQMessageByMessageId&Version=2021-04-01 HTTP/1.1
Accept: application/json
Content-Type: application/json
Host: rocketmq.volcengineapi.com
X-Date: 20210328T100802Z
Authorization: HMAC-SHA256 Credential=AK*********************/20210328/cn-beijing/rocketmq/request, SignedHeaders=x-date, Signature=*********************

{
  "Group": "GID-123",
  "MessageId": "******",
  "NeedMessageBody": false,
  "InstanceId": "******"
}

响应示例

{
  "ResponseMetadata": {
    "RequestId": "540CFF28-407A-40B5-B6A5-74B",
    "Action": "QueryDLQMessageByMessageId",
    "Version": "2021-04-01",
    "Service": "rocketmq",
    "Region": "cn-beijing"
  },
  "Result": {
    "Total": 1,
    "Messages": [
      {
        "MsgId": "****",
        "ProducerIP": "****",
        "MessageSize": 32,
        "Tags": "**",
        "MessageKeys": "****",
        "BornTimestamp": 1649330788,
        "StoreTimestamp": 1649330788,
        "Properties": {
          "": ""
        },
        "Body": "****",
        "Topic": "new",
        "ReconsumeTimes": 1649330788,
        "InstanceId": "*****",
        "BodyCRC": **
      }
    ],
    "msgNotExist": false,
    "shouldRetryQuery": false,
    "BatchMsgNotExist": {
      "": false
    },
    "BatchMsgShouldRetryQuery": {
      "": false
    }
  }
}