# 消息總線使用集成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定義，則可同時接收消息進行業務處理