返回介绍

1.7.6 查询 Message

发布于 2020-10-01 15:14:14 字数 3076 浏览 1042 评论 0 收藏 0

方法参数PeekMessageRequest

queueName : String : required
peekMessageArg : PeekMessageArg : required

查询消息输入的参数,提供三种查询参数模式,但是一次仅能选择一种. 三种查询参数模式是:

  1. receiptHandle : String 按消息发送成功时返回的消息id, 或者接收到消息时获取的消息句柄, 来查询消息.
  2. receiptHandleList : List 按消息发送成功时返回的消息id, 或者接收到消息时获取的消息句柄, 来批量查询消息.
  3. partitionTimeIntervalAndMaxNum : PartitionTimeIntervalAndMaxNum 按分片和时间区间来查询消息,并能限制每次查询返回的消息条数. PartitionTimeIntervalAndMaxNum的定义有四个字段:
    • startTimestamp : long : optional 起始时间
    • endTimestamp : long : optional 结束时间
    • maxNum : int : optional 最多返回的消息条数, 默认为200条
    • partitionId : int : optional 分片id,不填则系统随机选择

方法返回 list< PeekMessageResponse >

PeekMessageResponse包含的字段如下:

  1. messageID : String 消息ID
  2. messageBody : String 消息体
  3. messageAttributes : map< string, MessageAttribute > 用户自定义的消息属性
  4. e : GalaxyEmqServiceException 异常信息
  5. attributes : map< String, String > 系统定义的消息属性:
  6. 其中必定包含的内容有:
    • senderId
    • messageLength
    • md5OfBody
    • sendTimestamp
  7. 有可能会包含的内容有:
    • priority
    • receiveTimestamp
    • firstReceiveTimestamp
    • receiveCount
    • sourceQueueName
    • sourceTag
    • deadTimestamp
    • originalMessageID
    • originalReceiveCount
    • topic

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文