demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-10 15:11:59 +01:00
Code Issues Packages Projects Releases Wiki Activity

[ferroamp] Binding for ferroamp 20241126

Browse Source 
Changes done in FerroampHandler.java

Signed-off-by: Örjan Backsell <orjan.backsell@gmail.com>
This commit is contained in:
Örjan Backsell 2024-11-26 12:10:59 +01:00
parent e8ee223cb7
commit eb9a50e953
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
bundles/org.openhab.binding.ferroamp/src/main/java/org/openhab/binding/ferroamp/internal/FerroampHandler.java
View File

@ -84,6 +84,7 @@ public class FerroampHandler extends BaseThingHandler implements MqttMessageSubs
public void initialize() {
// Set configuration parameters
ferroampConfig = getConfigAs(FerroampConfiguration.class);
// Set channel configuration parameters
channelConfigEhub = FerroampChannelConfiguration.getChannelConfigurationEhub();
channelConfigSsoS1 = FerroampChannelConfiguration.getChannelConfigurationSsoS1();
@ -93,13 +94,11 @@ public class FerroampHandler extends BaseThingHandler implements MqttMessageSubs
channelConfigEso = FerroampChannelConfiguration.getChannelConfigurationEso();
channelConfigEsm = FerroampChannelConfiguration.getChannelConfigurationEsm();
if (ferroampConfig != null && channelConfigEhub != null && channelConfigSsoS1 != null
&& channelConfigSsoS2 != null && channelConfigSsoS3 != null && channelConfigSsoS4 != null
&& channelConfigEso != null && channelConfigEsm != null) {
if (ferroampConfig != null) {
FerroampConfiguration ferroampConfig = getConfigAs(FerroampConfiguration.class);
final MqttBrokerConnection ferroampConnection = new MqttBrokerConnection(ferroampConfig.hostName,
FerroampBindingConstants.BROKER_PORT, false, false, ferroampConfig.userName);
scheduler.scheduleWithFixedDelay(this::pollTask, 60, refreshInterval, TimeUnit.SECONDS);
this.setFerroampConnection(ferroampConnection);
updateStatus(ThingStatus.UNKNOWN);
@ -111,7 +110,7 @@ public class FerroampHandler extends BaseThingHandler implements MqttMessageSubs
private void pollTask() {
try {
startMqttConnection();
startMqttConnection(getConfigAs(FerroampConfiguration.class));
} catch (InterruptedException e) {
logger.debug("Not connected to the MqttBroker");
return;
@ -134,7 +133,7 @@ public class FerroampHandler extends BaseThingHandler implements MqttMessageSubs
}
}
private void startMqttConnection() throws InterruptedException {
private void startMqttConnection(FerroampConfiguration ferroampConfig) throws InterruptedException {
MqttBrokerConnection localSubscribeConnection = FerroampHandler.getFerroampConnection();