Compare commits

...

2 Commits

Author SHA1 Message Date
Hemna bb7a5ed08e don't dump the whole packet 2022-12-22 08:24:21 -05:00
Hemna a5ef1f10d4 use Tx to send 2022-12-22 08:21:33 -05:00
1 changed files with 4 additions and 2 deletions

View File

@ -8,6 +8,7 @@ import time
import aprsd.messaging
import paho.mqtt.client as mqtt
from aprsd import plugin, threads
from aprsd.threads import tx
LOG = logging.getLogger("APRSD")
@ -199,7 +200,7 @@ class WeewxMQTTThread(threads.APRSDThread):
def on_message(self, client, userdata, msg):
wx_data = json.loads(msg.payload)
LOG.debug(f"Got WX data {wx_data}")
LOG.debug("Got WX data")
# Make sure we have only 1 item in the queue
if self.msg_queue.qsize() >= 1:
self.msg_queue.clear()
@ -216,6 +217,7 @@ class WeewxMQTTThread(threads.APRSDThread):
self.client.disconnect()
def loop(self):
LOG.info("Loop")
self.client.loop_forever()
# self.client.loop(timeout=10, max_packets=10)
return True
@ -351,7 +353,7 @@ class WeewxWXAPRSThread(threads.APRSDThread):
# and then send it out to APRS
packet = self.build_wx_packet(wx)
packet.retry_count = 1
packet.send()
tx.send(packet)
self.last_send = datetime.datetime.now()
time.sleep(1)
return True