|
|
@@ -50,7 +50,7 @@ public class AppDeployer {
|
|
|
|
|
|
RpcMsg rpcMsg = RpcMsg.paramMsg(AppRpcClazz.class.getSimpleName(), AppRpcClazz.deploy.name(),
|
|
|
JsonConverter.objectToJson(deployParam));
|
|
|
- Message message = Message.rpcMsg(rpcMsg, MsgType.rpcParam);
|
|
|
+ Message message = Message.rpcParamMsg(rpcMsg);
|
|
|
|
|
|
// TODO 对于需要返回值的 pub,需要做一个记录,pub 和 sub 一一对应
|
|
|
String topic = MsgQueue.dagentTopic(Machine.ID);
|