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 static StackLogger logger = CommonLogger.getLogger(BlockingQueueDispatchAuditor.class);
    private long totalReject = 0;     
    private boolean started = false;
    private Queue<? extends Runnablequeue;
    private int timeout = 8000;
    public BlockingQueueDispatchAuditor(Queue<? extends Runnablequeue) {
    	this. = queue;
    }
    
    public void start(int interval) {
    	if(stop();
    	 = true;
    	 = new Timer();
    	.scheduleAtFixedRate(thisintervalinterval);
    }
    
    public int getTimeout() {
    	return ;
    }
    
    public void setTimeout(int timeout) {
    	this. = timeout;
    }
    public void stop() {
    	try {
    		.cancel();
    		 = null;
    	} catch (Exception e) {
    		//not important
    	} finally {
    		 = false;
    	}
    }
    public void run() {
    	try {
    		int removed = 0;
    		synchronized(this.) {
    			while(runnable != null) {
    				if(System.currentTimeMillis() - d.getReceptionTime() > ) {
    					.poll();
    					runnable = (QueuedMessageDispatchBasethis..peek();
    					removed ++;
    				} else {
    					runnable = null;
    				}
    			}
    		}
    		if(removed>0) {
    			+=removed;
    			if( != null && .isLoggingEnabled(.))
    				.logWarning("Removed stuck messages=" + removed +
    						" total rejected=" +  + " stil in queue=" + this..size());
    		}
    	} catch (Exception e) {
    		if( != null && .isLoggingEnabled(.)) {
				.logWarning("Problem reaping old requests. This is not a fatal error." + e);
			}
		}
	}
New to GrepCode? Check out our FAQ X