sendMessage 发送消息

说明

sendMessage() 作为生产者发送消息到 Redis, RabbitMQ, Kafka 等。

luwak.sendMessage('业务主题', '业务 ID', '业务附加数据');

发送消息

luwak.sendMessage("hrm.employee.created", 101, {id: 101, name: "Lillian Haddadi"});

luwak.sendMessage("hrm.payroll.processed", 101, {id: 101, name: "Lillian Haddadi"});

实际发送的内容

RabbitMq

{
  "mqName": "rabbitmq",
  "messageId": "cmchbbvctdnitv88prkg",
  "createdAt": "2024-01-06 16:56:15.955",
  "topicName": "hrm.employee.created",
  "bizId": 101,
  "bizData": {
    "id": 101,
    "name": "Lillian Haddadi"
  }
}

Kafka

{
  "mqName": "kafka",
  "messageId": "cmchbbvctdnitv88prl0",
  "createdAt": "2024-01-06 16:56:15.959",
  "topicName": "hrm.payroll.processed",
  "bizId": 101,
  "bizData": {
    "id": 101,
    "name": "Lillian Haddadi"
  }
}