# 消息总线使用集成2.4+ > 【发布订阅】本模块提供对消息总线的封装使用具体用法如下 [TOC=2] ## 1. 客户端发送消息 ``` //1.引入工具类 @Autowired private RabbitMqClient rabbitMqClient; //2.通过工具类推送消息 BaseMap params = new BaseMap(); params.put("orderId", "123456"); rabbitMqClient.publishEvent("demoBusEvent", params); ``` ## 2. 编写消息监听器 通过实现 `JeecgBusEventHandler ` ~~~ /** * 消息处理器 */ @Slf4j @Component("demoBusEvent") public class DemoBusEvent implements JeecgBusEventHandler { @Override public void onMessage(EventObj obj) { if (ObjectUtil.isNotEmpty(obj)) { BaseMap baseMap = obj.getBaseMap(); String orderId = baseMap.get("orderId"); log.info("业务处理----订单ID:" + orderId); } } } ~~~ 注:如果多个业务模块都存在相同的beanName定义,则可同时接收消息进行业务处理