Merge pull request #204 from FlowCI/develop

Develop

Author: yang.guo

platform-api/src/main/java/com/flow/platform/api/service/SyncServiceImpl.java

@@ -26,6 +26,7 @@
 import com.flow.platform.core.queue.PriorityMessage;
 import com.flow.platform.domain.Agent;
 import com.flow.platform.domain.AgentPath;
+import com.flow.platform.domain.AgentStatus;
 import com.flow.platform.domain.Cmd;
 import com.flow.platform.domain.CmdInfo;
 import com.flow.platform.domain.CmdResult;
@@ -95,6 +96,9 @@ private void init() {
 
                 List<Agent> agents = agentService.list();
                 for (Agent agent : agents) {
+                    if (agent.getStatus() == AgentStatus.OFFLINE) {
+                        continue;
+                    }
                     register(agent.getPath());
                 }
             } catch (Throwable e) {

platform-control-center/src/main/java/com/flow/platform/cc/consumer/CmdQueueConsumer.java

@@ -60,9 +60,6 @@ public class CmdQueueConsumer implements QueueListener<PriorityMessage> {
     @Autowired
     private CmdDispatchService cmdDispatchService;
 
-    @Autowired
-    private AgentService agentService;
-
     @Autowired
     private PlatformQueue<PriorityMessage> cmdQueue;