Refactoring: use default method for MQTT client credentials

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/mqtt/azure/AzureIotHubSasCredentials.java

@@ -24,7 +24,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.codec.binary.Base64;
 import org.bouncycastle.jce.provider.BouncyCastleProvider;
 import org.thingsboard.common.util.AzureIotHubUtil;
-import org.thingsboard.mqtt.MqttClientConfig;
 import org.thingsboard.rule.engine.mqtt.credentials.MqttClientCredentials;
 
 import javax.net.ssl.TrustManagerFactory;
@@ -59,10 +58,6 @@ public class AzureIotHubSasCredentials implements MqttClientCredentials {
         }
     }
 
-    @Override
-    public void configure(MqttClientConfig config) {
-    }
-
     private TrustManagerFactory createAndInitTrustManagerFactory() throws Exception {
         X509Certificate caCertHolder;
         caCertHolder = readCertFile(caCert);

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/mqtt/credentials/AnonymousCredentials.java

@@ -16,7 +16,6 @@
 package org.thingsboard.rule.engine.mqtt.credentials;
 
 import io.netty.handler.ssl.SslContext;
-import org.thingsboard.mqtt.MqttClientConfig;
 
 import java.util.Optional;
 
@@ -26,10 +25,5 @@ public class AnonymousCredentials implements MqttClientCredentials {
     public Optional<SslContext> initSslContext() {
         return Optional.empty();
     }
-
-    @Override
-    public void configure(MqttClientConfig config) {
-
-    }
 }
 

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/mqtt/credentials/CertPemClientCredentials.java

@@ -29,7 +29,6 @@ import org.bouncycastle.openssl.PEMKeyPair;
 import org.bouncycastle.openssl.jcajce.JcaPEMKeyConverter;
 import org.bouncycastle.openssl.jcajce.JcePEMDecryptorProviderBuilder;
 import org.springframework.util.StringUtils;
-import org.thingsboard.mqtt.MqttClientConfig;
 
 import javax.crypto.Cipher;
 import javax.crypto.EncryptedPrivateKeyInfo;
@@ -80,11 +79,6 @@ public class CertPemClientCredentials implements MqttClientCredentials {
         }
     }
 
-    @Override
-    public void configure(MqttClientConfig config) {
-
-    }
-
     private KeyManagerFactory createAndInitKeyManagerFactory() throws Exception {
         X509Certificate certHolder = readCertFile(cert);
         Object keyObject = readPrivateKeyFile(privateKey);

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/mqtt/credentials/MqttClientCredentials.java

@@ -36,6 +36,7 @@ public interface MqttClientCredentials {
 
     Optional<SslContext> initSslContext();
 
-    void configure(MqttClientConfig config);
+    default void configure(MqttClientConfig config) {
+    }
 }