private void queueWork ( Work work ) { try { logger . debug ( "Queueing work {}" , work ) ; executor . submit ( new EventWorker ( work , this ) ) ; } catch ( RejectedExecutionException e ) { logger . error ( "Unable to queue a received event! " , e ) ; } checkQueueSize ( ) ; }
puts work in the queue