Fx.mq:和mq消息有关的API
1. pub 发送消息,通过事件监听做消息路由匹配
Fx.mq.pub(<String channel>, <Map body>)
参数说明
参数 | 类型 | 说明 |
---|---|---|
channel | String | 消息通道,类似消息topic,不同业务使用不同channel;对应事件监听的消息通道值 |
body | Map | 消息内容 |
返回值类型
void
返回值说明
返回的数据类型: void
Java举例
Map body = Maps.of("key", "value", "xxxKey", "xxxValue");
Fx.mq.pub("xxx_channel", body)
Groovy举例
Map body = ["key": "value", "xxxKey": "xxxValue"]
Fx.mq.pub("xxx_channel", body)