QueryDLQMessageByMessageId--消息队列 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
    }
  }
}