while (up_queue.size() != 0){ Event tmp = (Event)up_queue.remove(); Message msg = decryptMessage(symDecodingCipher, (Message)tmp.getArg()); if (msg != null){ passUp(tmp); }
Event tmp =null; while ((tmp = (Event)upMessageQueue.poll(1L)) != null){    if (tmp != null){ Message msg = decryptMessage(symDecodingCipher, (Message)tmp.getArg());  if (msg != null){ if (log.isDebugEnabled()){ log.debug("passing up message from drain " + new String(msg.getBuffer())); } passUp(tmp); }else{ log.warn("discarding message in queue up drain as cannot decode it"); } }
	private  void drainUpQueue() throws QueueClosedException, Exception	{		synchronized(upLock){			while (up_queue.size() != 0){				Event tmp = (Event)up_queue.remove();				Message msg = decryptMessage(symDecodingCipher, (Message)tmp.getArg());				if (msg != null){					passUp(tmp);				}			}		}	}