
package org.openas2.processor.receiver;

import java.util.Map;
import java.util.Timer;
import java.util.TimerTask;

import org.openas2.OpenAS2Exception;
import org.openas2.Session;
import org.openas2.params.InvalidParameterException;


public abstract class PollingModule extends BaseReceiverModule {	
	public static final String PARAM_POLLING_INTERVAL = "interval";
	private Timer timer;
    private boolean busy;
	
	public void init(Session session, Map<String, String> options) throws OpenAS2Exception {
		super.init(session, options);
		getParameter(PARAM_POLLING_INTERVAL, true);		
	}

	public void setInterval(int seconds) {
		setParameter(PARAM_POLLING_INTERVAL, seconds);
	}

	public int getInterval() throws InvalidParameterException {		
		
			return getParameterInt(PARAM_POLLING_INTERVAL, true);
		
	}

	public abstract void poll();

	public void doStart() throws OpenAS2Exception {
		timer = new Timer(true);
		timer.scheduleAtFixedRate(new PollTask(), 0, getInterval() * 1000);
	}

	public void doStop() throws OpenAS2Exception {
		if (timer != null) {
			timer.cancel();
			timer = null;
		}
	}

	private class PollTask extends TimerTask {
		public void run() {
            if (!isBusy()) {
                setBusy(true);                
			     poll();
                 setBusy(false);
            } else {
                System.out.println("Miss tick");
            }
		}
	}

    public boolean isBusy() {
        return busy;
    }

    public void setBusy(boolean b) {
        busy = b;
    }

}

@@ -290,18 +290,20 @@
 nds 
-BaseReceiv
+MessageBuild
 erMo

Extend MessageBuilderModule which now contains the core processing functionality.