import org.apache.mesos.Protos;
import java.util.*;
public class DefaultPlanManager extends ChainedObserver implements PlanManager {
private final Plan plan;
public DefaultPlanManager(final Plan plan) {
<BUG>plan.getStrategy().interrupt();
this.plan = plan;</BUG>
this.plan.subscribe(this);
}
@Override

import org.apache.mesos.Protos;
import java.util.*;
public class DefaultPlanManager extends ChainedObserver implements PlanManager {
private final Plan plan;
public DefaultPlanManager(final Plan plan) {
plan.interrupt();
this.plan = plan;
this.plan.subscribe(this);
}
@Override
