private void handleException (TaskExecution aTask, Exception aException) {
    logger.error(aException.getMessage(),aException);
    SimpleTaskExecution task = SimpleTaskExecution.of(aTask);
    task.setError(new ErrorObject(aException.getMessage(),ExceptionUtils.getStackFrames(aException)));
    task.setStatus(TaskStatus.FAILED);
    messageBroker.send(Queues.ERRORS, task);
  }
Handle control tasks. Control tasks are used by the Coordinator
to control Worker instances. For example to stop an ongoing task
or to adjust something on a worker outside the context of a job.
src/main/java/com/creactiviti/piper/core/Worker.java