public Subscription subscribe()

in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java [51:55]

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

    public Subscription subscribe(SubscribeRequest request) {
        long startOffset = getStartOffset((MemoryPosition) request.getPosition(), request.getSeek());
        log.debug("Consuming from " + startOffset);
        return new TopicSubscription(startOffset, request.getCallback());
    }