gistfile1.java

  @Override
  public boolean process() throws IOException, InterruptedException {
    T msg = processNextMessage();
    if (msg != null) {
      return queue.offer(msg, offerTimeoutMillis, TimeUnit.MILLISECONDS);
    } else {
      // if its null, just try again
      return process();
    }
  }