public MqttSource()

in rcomp-mqtt/src/main/java/org/apache/karaf/rcomp/mqtt/MqttSource.java [33:39]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    public MqttSource(MqttClient client, String topic, Class<? extends T> type) {
        this.client = client;
        this.topic = topic;
        if (! type.equals(byte[].class)) {
            throw new IllegalArgumentException("Curently only byte[] is supported");
        }
    }