Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package gov.nist.javax.sip.stack;
 
 
 import java.util.Queue;
 import java.util.Timer;
 
public class BlockingQueueDispatchAuditor extends TimerTask {
	private Timer timer = new Timer();
	private StackLogger logger;
	private long totalReject = 0;     
	private boolean started = false;
	private Queue queue;
	private int timeout = 8000;
    public BlockingQueueDispatchAuditor(Queue queue) {
    	this. = queue;
    }
    
    public void setLogger(StackLogger logger) {
    	this. = logger;
    }
    
    public int getTimeout() {
    	return ;
    }
    
    public void setTimeout(int timeout) {
    	this. = timeout;
    }
    
    public void start(int interval) {
    	if(stop();
    	 = true;
    	 = new Timer();
    	.scheduleAtFixedRate(thisintervalinterval);
    }
    public void stop() {
    	try {
    		try {
    			if( != null.cancel();
    		} catch (Exception e) {
    			
    		}
    		 = null;
    		 = null;
    	} catch (Exception e) {
    		//not important
    	} finally {
    		 = false;
    	}
    }
	public void run() {
		try {
			int removed = 0;
			while(runnable != null) {
				if(System.currentTimeMillis() - d.getReceptionTime() > ) {
					runnable = (QueuedMessageDispatchBasethis..peek();
					removed ++;
else {
					runnable = null;
				}
			}
			if(removed>0) {
				+=removed;
					.logWarning("Removed stuck messages=" + removed +
							" total rejected=" +  + " stil in queue=" + this..size());
			}
catch (Exception e) {
				.logWarning("Problem reaping old requests. This is not a fatal error." + e);
			}
		}
	}
New to GrepCode? Check out our FAQ X