improvements

dao/src/main/java/org/thingsboard/server/dao/device/DeviceConnectivityConfiguration.java

@@ -19,13 +19,14 @@ import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.HashMap;
 import java.util.Map;
 
 @Configuration
 @ConfigurationProperties(prefix = "device")
 @Data
 public class DeviceConnectivityConfiguration {
-    private Map<String, DeviceConnectivityInfo> connectivity;
+    private Map<String, DeviceConnectivityInfo> connectivity = new HashMap<>();
 
     public boolean isEnabled(String protocol) {
         var info = connectivity.get(protocol);

dao/src/main/java/org/thingsboard/server/dao/device/DeviceConnectivityServiceImpl.java

@@ -37,6 +37,7 @@ import org.thingsboard.server.common.data.security.DeviceCredentials;
 import org.thingsboard.server.common.data.security.DeviceCredentialsType;
 import org.thingsboard.server.dao.util.DeviceConnectivityUtil;
 
+import javax.annotation.PostConstruct;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.net.URI;
@@ -78,8 +79,18 @@ public class DeviceConnectivityServiceImpl implements DeviceConnectivityService
     @Autowired
     private DeviceConnectivityConfiguration deviceConnectivityConfiguration;
 
-    @Autowired
-    private DeviceConnectivityServiceImpl deviceConnectivityService;
+    @PostConstruct
+    private void init() {
+        DeviceConnectivityInfo mqtts = deviceConnectivityConfiguration.getConnectivity().get(MQTTS);
+        if (mqtts != null && mqtts.isEnabled()) {
+            String certFilePath = mqtts.getPemCertFile();
+            if (StringUtils.isBlank(certFilePath) || !ResourceUtils.resourceExists(this, certFilePath)) {
+                String error = StringUtils.isBlank(certFilePath) ? "path is empty" : "file is not exists";
+                log.error("MQTTS is enabled but cert {}!", error);
+            }
+        }
+
+    }
 
     @Override
     public JsonNode findDevicePublishTelemetryCommands(String baseUrl, Device device) throws URISyntaxException {

dao/src/test/resources/application-test.properties

@@ -136,3 +136,5 @@ queue.rule-engine.queues[2].partitions=2
 queue.rule-engine.queues[2].processing-strategy.retries=1
 queue.rule-engine.queues[2].processing-strategy.pause-between-retries=0
 queue.rule-engine.queues[2].processing-strategy.max-pause-between-retries=0
+
+#device.connectivity=