问题描述

AppName: test-mservice-pos,InstanceId: test-mservice-pos-2800369692,taskId: 1766910317624937472 ,errorInfo: kd.bos.exception.KDException: mq error: app bree not support broadcast
 at kd.bos.mq.rabbit.RabbitBroadcast.broadcastMessage(RabbitBroadcast.java:177)
 at kd.bos.mq.broadcast.BroadcastService.broadcastMessageWithApp(BroadcastService.java:110)
 at kd.bos.schedule.server.broadcast.BroadcastMessageSender.send(BroadcastMessageSender.java:77)
 at kd.bos.schedule.server.JobDispatcherProxy.dispatch(JobDispatcherProxy.java:124)
 at kd.bos.schedule.server.messagecustomer.AsynJobMessageDispatcher.onMessage(AsynJobMessageDispatcher.java:50)
 at kd.bos.mq.rabbit.RabbitConsumer.doTraceAndConsume(RabbitConsumer.java:576)
 at kd.bos.mq.rabbit.RabbitConsumer._handleDelivery(RabbitConsumer.java:447)
 at kd.bos.mq.rabbit.RabbitConsumer.innerHandleDelivery(RabbitConsumer.java:243)
 at kd.bos.mq.rabbit.RabbitConsumer.lambda$handleDelivery$0(RabbitConsumer.java:196)
 at kd.bos.threads.impl.ThreadPoolImpl.lambda$execute$0(ThreadPoolImpl.java:57)
 at kd.bos.threads.impl.RequestContextRunnable.run(RequestContextRunnable.java:60)
 at kd.bos.thread.ThreadLifeCycleManager$RunnableWrap.run(ThreadLifeCycleManager.java:260)
 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
 at java.lang.Thread.run(Thread.java:748)

解决方法

MC参数 broadcast.support.appids 的 值 新增 appid ，如bree。 Schedule.properties  = bos,bree（逗号区分）

需要重启所有节点才能生效