allInternalTasks = (IncrementalSubscription) subscribe(new UnaryPredicate() { public boolean execute(Object obj) { if (obj instanceof Task) { Task task = (Task) obj; return (task.getPrepositionalPhrase(GenericPlugin.INTERNAL) != null); } return false; } } );
  protected void setupSubscriptions() {    super.setupSubscriptions();    ProportionalDistributor.DEFAULT_PROPORTIONAL_DISTRIBUTOR.setLoggingService(getLoggingService());  }