public CloseableSubscriber to()

in rcomp-camel/src/main/java/org/apache/karaf/rcomp/camel/CamelComponent.java [73:75]

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

    public <T> CloseableSubscriber<T> to(String topic, Class<T> type) {
        return new CloseableSubscriberAdapter<T>(camelreactive.subscriber(topic, type));
    }