boolean reforkNeeded = false;
final ReforkController reforkController = pipeline.getReforkController();
if (reforkController != null) {
final ReforkDecisionContext reforkDecisionContext = message.getReforkDecisionContext();
if (reforkDecisionContext != null) {
<BUG>reforkNeeded = reforkController.reforkNeeded(reforkDecisionContext);
</BUG>
}
}
return reforkNeeded;

boolean reforkNeeded = false;
final ReforkController reforkController = pipeline.getReforkController();
if (reforkController != null) {
final ReforkDecisionContext reforkDecisionContext = message.getReforkDecisionContext();
if (reforkDecisionContext != null) {
reforkNeeded = reforkController.reforkNeeded(pipeline, message.getForkId(), reforkDecisionContext);
}
}
return reforkNeeded;
