Fx.mq

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)

2024-09-15
3 1