public void onNext()

in rcomp-mqtt/src/main/java/org/apache/karaf/rcomp/mqtt/MqttDestination.java [45:54]

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

    public void onNext(T payload) {
        try {
            MqttMessage message = new MqttMessage(convertTo(payload));
            this.client.publish(topic, message);
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            subscription.request(1);
        }
    }