public void activate()

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

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

    public void activate(MqttConfig config) throws MqttException {
        client = new MqttClient(config.serverUrl(), MqttClient.generateClientId(),
                                new MemoryPersistence());
        MqttConnectOptions options = new MqttConnectOptions();
        options.setAutomaticReconnect(true);
        options.setUserName(config.userName());
        if (config.password() != null) {
            options.setPassword(config.password().toCharArray());
        }
        client.connect(options);
    }