|
@ -65,7 +65,7 @@ public class ServiceShellEventService {
|
|
|
String msg = objectMapper.writeValueAsString(serviceShell);
|
|
|
String tenant = LocalContext.getContext().getAttachment(ContextAttributes.TENANT_NAME);
|
|
|
|
|
|
Producer producer = new Producer(zbusBroker, ServiceFlowConstant.SHELL_ARBITER + "@" + tenant);
|
|
|
Producer producer = new Producer(zbusBroker, ServiceFlowConstant.SHELL_REQUEST + "@" + tenant);
|
|
|
producer.createMQ(); //确定为创建消息队列需要显示调用
|
|
|
Message message = new Message();
|
|
|
message.setHead("event", event);
|