MQTT - как проверить порт и IP запущен в mqtt

Question

Я пытаюсь проверить данный IP и порт, работающий или нет, если нет, то я должен вернуть исключение клиенту.

Вот мой код,

MqttMessage message2 = new MqttMessage(); 
MQTT mqtt_connect = new MQTT(); 
mqtt_connect.setHost(Host_Address, Integer.parseInt(port)); 
String topic = "/call/MQTT_Config"; 
mqtt_connect.setClientId("MQTT_Config"); 
mqtt_connect.setWillRetain(false); 
mqtt_connect.isWillRetain(); 
mqtt_connect.setWillTopic(topic); 
BlockingConnection m_publisher = mqtt_connect.blockingConnection(); 
m_publisher.connect(); 
if(connection establish){ 
    // here how to check the condition 
    do publish here 
} 
else{ 
    return "connection failure"; 
} 

Кто-то сказать мне проверку в моем коде.

Answer 1

Итогового код в Try/улове, как следовать

try{ 
    MqttMessage message2 = new MqttMessage(); 
    MQTT mqtt_connect = new MQTT(); 
    mqtt_connect.setHost(Host_Address, Integer.parseInt(port)); 
    String topic = "/call/MQTT_Config"; 
    mqtt_connect.setClientId("MQTT_Config"); 
    mqtt_connect.setWillRetain(false); 
    mqtt_connect.isWillRetain(); 
    mqtt_connect.setWillTopic(topic); 
    BlockingConnection m_publisher = mqtt_connect.blockingConnection(); 
    m_publisher.connect(); 

} 
catch(Exception e){ 
    add message for connection not established 
}