...
 private  BlockingQueue<LogRecord> log =  new  LinkedBlockingQueue<LogRecord>();

	
	 private   class  Runner  implements  Runnable {	
		 public   void  run()
		{
			lg.info(Messages.getString("CallLog.Started")); 
			LogRecord rec;
			 try  {
				 while  (!Thread.currentThread().isInterrupted()) {
					rec = log.take();
					doLog(rec);
				}			
			}  catch  (InterruptedException e) {
				
			}		
			flush();
			lg.info(Messages.getString("CallLog.LogFlushed")); 
			
			closeLogWriters();
			lg.info(Messages.getString("CallLog.Stopped")); 
		}		
	}