private void poll()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java [109:125]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    private void poll(MessageReceiver receiver) {
        while (!interrupted()) {
            try {
                Message message = receiver.receive(index);
                LOGGER.debug("Received: " + message);
                Received received = new Received(position(index), message);
                consumer.accept(received);
                index += 1L;
            } catch (InterruptedException e) {
                currentThread().interrupt();
            } catch (Exception e) {
                LOGGER.error("Error handling message", e);
            }
        }
        LOGGER.debug("Quitting " + this);
        receiver.close();
    }