*/\r
package org.onap.nbi.apis.serviceorder.workflow;\r
\r
-import java.util.*;\r
-import java.util.Map.Entry;\r
import org.onap.nbi.apis.serviceorder.model.OrderItemRelationship;\r
import org.onap.nbi.apis.serviceorder.model.ServiceOrder;\r
import org.onap.nbi.apis.serviceorder.model.ServiceOrderItem;\r
import org.slf4j.LoggerFactory;\r
import org.springframework.beans.factory.annotation.Autowired;\r
import org.springframework.scheduling.annotation.EnableScheduling;\r
-import org.springframework.scheduling.annotation.Scheduled;\r
import org.springframework.stereotype.Service;\r
\r
+import java.util.*;\r
+import java.util.Map.Entry;\r
+\r
@Service\r
@EnableScheduling\r
public class SOTaskManager {\r
registerOrderItemExecutionPlan(serviceOrder.getOrderItem(), serviceOrderInfoJson);\r
}\r
\r
- // Using fixedDelay to mitigate against Scheduler queue backlog with fixedRate \r
- @Scheduled(fixedDelay = 2000)\r
- private void processExecutionPlan() throws InterruptedException {\r
- List<ExecutionTask> taskToExecute = executionTaskRepository.findByReliedTasksIsEmpty();\r
- for (ExecutionTask executionTask : taskToExecute) {\r
- soTaskProcessor.processOrderItem(executionTask);\r
- }\r
- }\r
+\r
}\r