public boolean hasNext()

in pulsar-client-kafka-compat/pulsar-client-kafka_0_8/src/main/java/org/apache/kafka/clients/simple/consumer/PulsarByteBufferMessageSet.java [59:72]

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

        public boolean hasNext() {
            try {
                org.apache.pulsar.client.api.Message<byte[]> msg = reader.readNext(10, TimeUnit.MILLISECONDS);
                if (msg != null) {
                    receivedMessages.offer(msg);
                    return true;
                }
            } catch (PulsarClientException e) {
                if (log.isDebugEnabled()) {
                    log.debug("Failed to receive message for {}, {}", reader.getTopic(), e.getMessage());
                }
            }
            return false;
        }