Commit 4fa01369 by huangfusuper

增加部分注释 删除多余代码

parent 2e83f196
...@@ -39,7 +39,7 @@ public class AdminRegisterConfig { ...@@ -39,7 +39,7 @@ public class AdminRegisterConfig {
return invokerFactory; return invokerFactory;
} }
@Bean /*@Bean
public RpcSpringProviderFactory rpcSpringProviderFactory() { public RpcSpringProviderFactory rpcSpringProviderFactory() {
RpcSpringProviderFactory providerFactory = new RpcSpringProviderFactory(); RpcSpringProviderFactory providerFactory = new RpcSpringProviderFactory();
//providerFactory.setPort(port); //providerFactory.setPort(port);
...@@ -52,6 +52,6 @@ public class AdminRegisterConfig { ...@@ -52,6 +52,6 @@ public class AdminRegisterConfig {
log.info(">>>>>>>>>>>>>>> byit-myth-admin 向注册中心注册config初始化完成"); log.info(">>>>>>>>>>>>>>> byit-myth-admin 向注册中心注册config初始化完成");
return providerFactory; return providerFactory;
} }*/
} }
...@@ -87,7 +87,7 @@ public class RpcSpringInvokerFactory extends InstantiationAwareBeanPostProcessor ...@@ -87,7 +87,7 @@ public class RpcSpringInvokerFactory extends InstantiationAwareBeanPostProcessor
null, null,
rpcInvokerFactory rpcInvokerFactory
); );
//获取一个代理对象
Object serviceProxy = referenceBean.getObject(); Object serviceProxy = referenceBean.getObject();
// set bean // set bean
......
...@@ -82,7 +82,7 @@ public abstract class ConnectClient { ...@@ -82,7 +82,7 @@ public abstract class ConnectClient {
if (connectClient!=null && connectClient.isValidate()) { if (connectClient!=null && connectClient.isValidate()) {
return connectClient; return connectClient;
} }
//获取对应地址的锁对象
// lock // lock
Object clientLock = connectClientLockMap.get(address); Object clientLock = connectClientLockMap.get(address);
if (clientLock == null) { if (clientLock == null) {
......
...@@ -19,7 +19,7 @@ public class AddComplexPy { ...@@ -19,7 +19,7 @@ public class AddComplexPy {
runNode.setNodeId("2"); runNode.setNodeId("2");
runNode.setNodeName("lijkki"); runNode.setNodeName("lijkki");
runNode.setRunCmd("python ${biz_file}"); runNode.setRunCmd("python ${biz_file}");
JobUtils.setRequestUrl("http://127.0.0.1:8081/myth-job-admin"); JobUtils.setRequestUrl("http://10.0.120.208:8081/myth-job-admin/");
JobUtils.setTOKEN("test"); JobUtils.setTOKEN("test");
JobUtils.realExectNode(runNode); JobUtils.realExectNode(runNode);
/* PluginPackage pluginPackage = new PluginPackage(); /* PluginPackage pluginPackage = new PluginPackage();
......
...@@ -16,7 +16,7 @@ public class AddComplexPy1 { ...@@ -16,7 +16,7 @@ public class AddComplexPy1 {
PluginPackage pluginPackage = new PluginPackage(); PluginPackage pluginPackage = new PluginPackage();
pluginPackage.setWorkspaceName("test"); pluginPackage.setWorkspaceName("test");
pluginPackage.setFlow(createFlow()); pluginPackage.setFlow(createFlow());
JobUtils.setRequestUrl("http://127.0.0.1:8081/myth-job-admin"); JobUtils.setRequestUrl("http://10.0.120.208:8081/myth-job-admin");
JobUtils.setTOKEN("test"); JobUtils.setTOKEN("test");
JobUtils.publish(pluginPackage); JobUtils.publish(pluginPackage);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment