生产者 MQProducer

MQ的消息生产者

class MQProducer()

构造函数 new MQProducer(client, instanceId, topic)

参数

• client (MQClient) – MQ的客户端

• instanceId (String) – 实例ID

• topic (String) – 主题名字

方法

<async> publishMessage(body, tag, msgProps)

向主题发送一条消息

参数

• body (String) – 发送的内容

• tag (String) – 发送消息的标签

• msgProps (MessageProperties) – 发送消息的属性

返回类型

object

返回

{
  // http请求状态码，发送成功就是201，如果发送失败则抛异常
  code: 201,
  // 请求ID
  requestId: "xxxxxxxxxxxxxx",
  // 发送消息的响应内容
  body: {
    // 消息ID
    MessageId: "",
    // 消息体内容的MD5值
    MessageBodyMD5: ""
  }
}

抛出

exception –

err MQ服务端返回的错误或者其它网络异常

{
  // MQ服务端返回的错误Code，like: TopicNotExist
  Code:"",
  // 请求ID
  RequestId:""
}