Executor humidity #104
|
@ -1,4 +1,4 @@
|
||||||
package ch.unisg.executorBase.executor.application.service;
|
package ch.unisg.executorbase.executor.application.service;
|
||||||
|
|
||||||
import ch.unisg.common.valueobject.ExecutorURI;
|
import ch.unisg.common.valueobject.ExecutorURI;
|
||||||
import ch.unisg.executorbase.executor.application.port.out.NotifyExecutorPoolPort;
|
import ch.unisg.executorbase.executor.application.port.out.NotifyExecutorPoolPort;
|
||||||
|
|
|
@ -89,6 +89,6 @@ public abstract class ExecutorBase {
|
||||||
* Implementation of the actual execution method of an executor
|
* Implementation of the actual execution method of an executor
|
||||||
* @return the execution result
|
* @return the execution result
|
||||||
**/
|
**/
|
||||||
protected abstract String execution(String input) throws ConnectorException, IOException, ConnectorException;
|
protected abstract String execution(String input);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -27,7 +27,7 @@ public class TaskAvailableController {
|
||||||
if (ExecutorType.contains(taskType.toUpperCase())) {
|
if (ExecutorType.contains(taskType.toUpperCase())) {
|
||||||
TaskAvailableCommand command = new TaskAvailableCommand(
|
TaskAvailableCommand command = new TaskAvailableCommand(
|
||||||
ExecutorType.valueOf(taskType.toUpperCase()));
|
ExecutorType.valueOf(taskType.toUpperCase()));
|
||||||
CompletableFuture.runAsync(() -> taskAvailableUseCase.newTaskAvailable(command);
|
CompletableFuture.runAsync(() -> taskAvailableUseCase.newTaskAvailable(command));
|
||||||
}
|
}
|
||||||
|
|
||||||
// Add the content type as a response header
|
// Add the content type as a response header
|
||||||
|
|
Loading…
Reference in New Issue
Block a user