PhaseInfo phase = getCurrentPhase();
    public void prepareToWork() {	if (!Stream.scheduledRun && !(this instanceof ChannelConnectFilter)) {	    // this is where phase is advanced for unscheduled run	    PhaseInfo phase = getCurrentPhase();	    advancePhase();	    	    // if the phase is static-rate, we require enough inputs	    // to execute the whole phase.  This ensures that all	    // upstream messages are sent (and hence received by this	    // filter) prior to execution.	    if (phase.e!=Rate.DYNAMIC_RATE && phase.e>0) {		input.ensureData(phase.e);	    }	}	super.prepareToWork();    }