protected void asyncOneWay(Object command) throws IOException{ try{ synchronized(mutex){ if(messageQueue==null){messageQueue=new LinkedBlockingQueue(this.asyncQueueDepth);
} } messageQueue.put(command); wakeup(); }catch(final InterruptedException e){ log.error("messageQueue interupted",e); throw new IOException(e.getMessage()); } }