private MongoSubscription()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoSubscription.java [93:107]

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

    private MongoSubscription(
            MessageReceiver receiver, long index, Consumer<Received> consumer
    ) {
        this.consumer = consumer;
        this.receiver = receiver;
        if (index == EARLIEST_INDEX) {
            this.index = receiver.earliestIndex();
        } else if (index == LATEST_INDEX) {
            this.index = receiver.latestIndex();
        } else {
            this.index = index;
        }
        this.index = index == LATEST_INDEX ? receiver.latestIndex() : index;
        startBackgroundThread(() -> poll(receiver), "MongoMessageConsumer-" + receiver);
    }