} catch (Throwable t) {
LOGGER.error("failed to handle " + message, t);
}
} else {
LOGGER.error("received unknown message of type {} on pipeline ", messageClass,
<BUG>pipeline.getConfig().getName());
ioSession.write(new StopForkActionMessage(pipeline.getId()));</BUG>
}
}
}

} catch (Throwable t) {
LOGGER.error("failed to handle " + message, t);
}
} else {
LOGGER.error("received unknown message of type {} on pipeline ", messageClass,
pipeline.getName());
ioSession.write(new StopForkActionMessage(pipeline.getId()));
}
}
}
