@Override
  public void dispatch(TaskExecution aTask) {
    Map<String, Object> params = new HashMap<>();
    params.put(DSL.INPUTS, aTask.getMap(DSL.INPUTS, Collections.emptyMap()));
    params.put(DSL.PARENT_TASK_EXECUTION_ID, aTask.getId());
    params.put(DSL.PIPELINE_ID, aTask.getRequiredString(DSL.PIPELINE_ID));
    messageBroker.send(Queues.SUBFLOWS, params);
  }
a {@link TaskDispatcher} implementation which handles the 'subflow' 
task type. Subflows are essentially isolated job instances started 
by the parent 'subflow' task which is the owner of the sub-flow. 

@author Arik Cohen
@since Sep 06, 2018
src/main/java/com/creactiviti/piper/core/task/SubflowTaskDispatcher.java