public void stop()

in src/main/java/org/apache/sling/event/dea/impl/DistributedEventSender.java [119:132]

• 13 lines of code
• 3 McCabe index (conditional complexity)

    public void stop() {
        if ( this.serviceRegistration != null ) {
            this.serviceRegistration.unregister();
            this.serviceRegistration = null;
        }
        // stop background threads by putting empty objects into the queue
        this.running = false;
        try {
            this.queue.put("");
        } catch (final InterruptedException e) {
            this.ignoreException(e);
            Thread.currentThread().interrupt();
        }
    }