public Subscription subscribe()

in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/InMemoryMessaging.java [54:58]

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

    public Subscription subscribe(SubscribeRequestBuilder requestBuilder) {
        SubscribeRequest request = requestBuilder.build();
        Topic topic = getOrCreate(request.getTopic());
        return topic.subscribe(request);
    }