2 Commits
0.0.2 ... 0.0.5

3 changed files with 3 additions and 3 deletions

View File

@ -12,7 +12,7 @@ def modbusStart(config, processImage):
def modbusHandler(config, processImage): def modbusHandler(config, processImage):
modbusClient = config["modbus"]["client"] modbusClient = config["modbus"]["client"]
modbusRefreshPeriod = config["modbus"]["scanrate"] modbusRefreshPeriod = float(config["modbus"]["scanrate"])
client = ModbusClient(modbusClient) client = ModbusClient(modbusClient)

View File

@ -15,7 +15,7 @@ class MqttCoilSubscriber(AbstractMqttPublisher):
def localLoop(self): def localLoop(self):
while True: while True:
sleep(self.config["analogInputPublishPeriod"]) sleep(float(self.config["analogInputPublishPeriod"]))
def onMessage(self, topic, payload): def onMessage(self, topic, payload):
logger.warning("mqtt message received: {} -> {}".format(topic, str(payload))) logger.warning("mqtt message received: {} -> {}".format(topic, str(payload)))

View File

@ -28,5 +28,5 @@ class MqttPeriodPublisher(AbstractMqttPublisher):
self.client.publish("{}/{}".format(self.config["analogInputPeriodicTopicPrefix"], str(analogInputItem[0])), self.client.publish("{}/{}".format(self.config["analogInputPeriodicTopicPrefix"], str(analogInputItem[0])),
str(analogInputItem[1])) str(analogInputItem[1]))
sleep(self.config["analogInputPublishPeriod"]) sleep(float(self.config["analogInputPublishPeriod"]))