hemna
/
aprsd-weewx-plugin
mirror of https://github.com/hemna/aprsd-weewx-plugin.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

use Tx to send

This commit is contained in:
Hemna 2022-12-22 08:21:33 -05:00
parent d7260fbd71
commit a5ef1f10d4
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
aprsd_weewx_plugin/weewx.py
View File

@ -8,6 +8,7 @@ import time
import aprsd.messaging import aprsd.messaging
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
from aprsd import plugin, threads from aprsd import plugin, threads
from aprsd.threads import tx
LOG = logging.getLogger("APRSD") LOG = logging.getLogger("APRSD")
@ -216,6 +217,7 @@ class WeewxMQTTThread(threads.APRSDThread):
self.client.disconnect() self.client.disconnect()
def loop(self): def loop(self):
LOG.info("Loop")
self.client.loop_forever() self.client.loop_forever()
# self.client.loop(timeout=10, max_packets=10) # self.client.loop(timeout=10, max_packets=10)
return True return True
@ -351,7 +353,7 @@ class WeewxWXAPRSThread(threads.APRSDThread):
# and then send it out to APRS # and then send it out to APRS
packet = self.build_wx_packet(wx) packet = self.build_wx_packet(wx)
packet.retry_count = 1 packet.retry_count = 1
packet.send() tx.send(packet)
self.last_send = datetime.datetime.now() self.last_send = datetime.datetime.now()
time.sleep(1) time.sleep(1)
return True return True