code: 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();
      }
docs: puts work in the queue
  @param work the work to do