rdkartono/FA_Gateway_Java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
rdkartono
2025-06-14 14:28:50 +07:00
parent 241fa0edd9
commit 9fd167c0f8
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/Main.java
View File

@@ -26,6 +26,17 @@ public class Main {
}, pinStatus -> { }, pinStatus -> {
// TODO Handle pin status updates here // TODO Handle pin status updates here
Logger.info("Gpio {}, Description {}, status updated to {}", pinStatus.getGpioNumber(), pinStatus.getDescription(), pinStatus.getStatus()); Logger.info("Gpio {}, Description {}, status updated to {}", pinStatus.getGpioNumber(), pinStatus.getDescription(), pinStatus.getStatus());
// MQTT publish pin status update
if (mqttClient != null && mqttClient.isConnected()) mqttClient.Publish(config.getMQTT_Topic(), config.getMQTT_ClientID(),
String.format("Gpio %d, Description %s, Status %d", pinStatus.getGpioNumber(), pinStatus.getDescription(), pinStatus.getStatus()),
published -> {
if (published) {
Logger.info("Pin status update published successfully.");
} else {
Logger.error("Failed to publish pin status update.");
}
});
// Email notification can be added here
}, },
@@ -57,6 +68,7 @@ public class Main {
// Add a shutdown hook to disconnect all services // Add a shutdown hook to disconnect all services
Runtime.getRuntime().addShutdownHook(new Thread(() -> { Runtime.getRuntime().addShutdownHook(new Thread(() -> {
if (gpio!=null && gpio.IsOpened()) gpio.Close();
if (mqttClient!=null && mqttClient.isConnected()) mqttClient.Disconnect(); if (mqttClient!=null && mqttClient.isConnected()) mqttClient.Disconnect();
})); }));
} }