Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
8120df60ac
|
@ -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)))
|
||||||
|
Reference in New Issue
Block a user