广播消息

在消费者的注解中添加声明：messageMode=MessageExtConst.MESSAGE_MODE_BROADCASTING

@MQConsumer(topic = "suclogger", consumerGroup = "wms.tms.topic", messageMode=MessageExtConst.MESSAGE_MODE_BROADCASTING)
class DemoConsumer : AbstractMQPushConsumer<DemoMessage>() {
    override fun process(message:DemoMessage) : Boolean {
        return true
    }
}