320321322323324325326327328
if (this.missingQueues.size() > 0) { checkMissingQueues(); } Message message = handle(queue.poll(timeout, TimeUnit.MILLISECONDS)); if (message == null && cancelReceived.get()) { throw new ConsumerCancelledException(); } return message; }