public CloseableSubscriber to()

in rcomp-mqtt/src/main/java/org/apache/karaf/rcomp/mqtt/MqttComponent.java [86:91]

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

    public <T> CloseableSubscriber<T> to(String topic, Class<T> type) {
        LOGGER.info("Creating mqtt Subscriber on topic " + topic);
        MqttDestination<T> destination = new MqttDestination<T>(client, topic, type);
        destinations.add(destination);
        return destination;
    }