public Subscription subscribe()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MongoMessaging.java [59:64]

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

    public Subscription subscribe(SubscribeRequestBuilder requestBuilder) {
        SubscribeRequest request = requestBuilder.build();
        MongoCollection<Document> collection = database.getCollection(request.getTopic());
        MessageReceiver receiver = messageReceiver(collection);
        return subscription(receiver, index(request.getPosition()), request.getSeek(), request.getCallback());
    }