import jade.core.behaviours.WakerBehaviour; //导入依赖的package包/类
private void handleError() {
    if (this.retries > 0 && this.timeout > 0) {
        logger.warn("Action is delayed.");
        this.myAgent.addBehaviour(new WakerBehaviour(this.myAgent, timeout) {

            @Override
            protected void onWake() {
                super.onWake();
                this.myAgent.addBehaviour(new FTPUpLoadRequestInitiatorBehaviour(
                        this.myAgent,
                        FTPUpLoadRequestInitiatorBehaviour.this.source,
                        FTPUpLoadRequestInitiatorBehaviour.this.destination,
                        FTPUpLoadRequestInitiatorBehaviour.this.timeout,
                        FTPUpLoadRequestInitiatorBehaviour.this.retries - 1));
            }
        });
    } else {
        logger.warn("Action is aborted: file " + this.source.getAbsolutePath() + " not transmitted.");
    }
}
 

import jade.core.behaviours.WakerBehaviour; //导入依赖的package包/类
/** Completes the evaluation process, updating the dispatched agents of the 
 *event .
 */
public void complete() {
    System.err.println("Completed successfully. Releasing sent agents...");
    
    String sCur;
    Object oNext;
    // For every agent
    while ((oNext=ActiveAgents.poll()) != null) {
        sCur = (String)oNext;
        // Send termination signal
        ACLMessage msg = new ACLMessage(ACLMessage.CANCEL);
        msg.setSender(getAID());
        msg.addReceiver(new AID(sCur, false));
        msg.setContent(NGramDocumentComparatorAgent.TERMINATION_MESSAGE);

        send(msg);        
    }
    psOutputStream.flush();
    psOutputStream.close();
    
    addBehaviour(new WakerBehaviour(this, 10000) {
        public void onWake() {
            doDelete();
        }
    });
    
}