if ( oldConsumer.equals(info) && oldConsumer.executor != null ) {
// notify listener
for(final Object[] listenerObjects : this.listenerMap.values()) {
if ( listenerObjects[0] == oldConsumer.executor ) {
final JobExecutionContext context = (JobExecutionContext)listenerObjects[1];
context.asyncProcessingFinished(context.result().failed());
break;
}
}
}
}