File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
platform-control-center/src/main/java/com/flow/platform/cc/consumer Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -96,13 +96,15 @@ public void onQueueItem(Message message) {
9696 LOGGER .trace ("wait for idle agent time out %s seconds for cmd %s" , idleAgentTimeout , cmdId );
9797 }
9898
99- // reset cmd status to pending, record num of retry
100- int retry = item .getRetry () - 1 ;
10199 Cmd cmd = cmdService .find (cmdId );
100+
101+ // do not re-enqueue if cmd been stopped or killed
102102 if (cmd .getStatus () == CmdStatus .STOPPED || cmd .getStatus () == CmdStatus .KILLED ) {
103103 return ;
104104 }
105105
106+ // reset cmd status to pending, record num of retry
107+ int retry = item .getRetry () - 1 ;
106108 cmd .setStatus (CmdStatus .PENDING );
107109 cmd .setRetry (retry );
108110 cmdService .save (cmd );
You can’t perform that action at this time.
0 commit comments