private void processWriteQueue()

in src/main/java/org/apache/sling/event/dea/impl/DistributedEventReceiver.java [196:217]

• 21 lines of code
• 6 McCabe index (conditional complexity)

    private void processWriteQueue() {
        while ( this.running ) {
            // so let's wait/get the next event from the queue
            Event event = null;
            try {
                event = this.writeQueue.take();
            } catch (final InterruptedException e) {
                this.ignoreException(e);
                Thread.currentThread().interrupt();
                this.running = false;
            }
            if ( event != null && this.running ) {
                try {
                    this.writeEvent(event);
                    successCounter.incrementAndGet();
                } catch (final Exception e) {
                    this.logger.error("Exception during writing the event to the resource tree.", e);
                    failureCounter.incrementAndGet();
                }
            }
        }
    }