|
|
@@ -9,8 +9,8 @@ import cn.reghao.devops.agent.config.DagentConfig;
|
|
|
import cn.reghao.devops.agent.task.ImageCleanTask;
|
|
|
import cn.reghao.devops.common.agent.app.iface.AppDeploy;
|
|
|
import cn.reghao.devops.common.agent.app.iface.AppStat;
|
|
|
-import cn.reghao.devops.common.agent.app.iface.impl.AppDeployService;
|
|
|
-import cn.reghao.devops.common.agent.app.iface.impl.AppStatService;
|
|
|
+import cn.reghao.devops.common.agent.app.iface.impl.AppDeployImpl;
|
|
|
+import cn.reghao.devops.common.agent.app.iface.impl.AppStatImpl;
|
|
|
import cn.reghao.devops.common.agent.app.iface.impl.DockerApp;
|
|
|
import cn.reghao.devops.common.docker.Docker;
|
|
|
import cn.reghao.devops.common.docker.DockerImpl;
|
|
|
@@ -66,8 +66,8 @@ public class AgentApp {
|
|
|
|
|
|
static MessageSender getMessageSender(DagentConfig dagentConfig) {
|
|
|
DockerApp dockerApp = new DockerApp(docker);
|
|
|
- AppDeploy appDeploy = new AppDeployService(dockerApp);
|
|
|
- AppStat appStat = new AppStatService(dockerApp);
|
|
|
+ AppDeploy appDeploy = new AppDeployImpl(dockerApp);
|
|
|
+ AppStat appStat = new AppStatImpl(dockerApp);
|
|
|
|
|
|
if (tryConnect(dagentConfig.getManagerAddress(), dagentConfig.getManagerPort())) {
|
|
|
messageSender = new WsClient(dagentConfig, scheduler, appDeploy, appStat);
|
