ClassLoader fireUntilHaltLoader = Classes.getTCCL();
if (fireUntilHaltLoader == null) {
fireUntilHaltLoader = getLoader();
}
FireUntilHalt fireUntilHalt = new FireUntilHalt(this, session, fireUntilHaltLoader);
session.addDisposals(fireUntilHalt);
_fireUntilHaltThread = fireUntilHalt.startThread();
}
final String undefinedVariable = toVariable(exchange);
Map<String, List<Object>> inputMap = getListMap(inputMessage, operation.getInputExpressionMappings(), true, undefinedVariable);
if (inputMap.size() > 0) {