while(down_queue.size() != 0){ sendDown((Event)down_queue.remove());
Event tmp =null; while((tmp = (Event)downMessageQueue.poll(1L) )!= null){ sendDown(tmp);
	private void drainDownQueue() throws Exception, QueueClosedException	{		synchronized(downLock){			// first lets replay any oustanding events			while(down_queue.size() != 0){				sendDown((Event)down_queue.remove());			}		}	}