public Publisher from()

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

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

    public <T> Publisher<T> from(String topic, Class<T> type) {
        LOGGER.info("Creating mqtt Publisher on topic " + topic);
        return new MqttSource<T>(client, topic, type);
    }