From 25f27fd5b0a28848c85adf88cf284044f5f2dccc Mon Sep 17 00:00:00 2001 From: Nat Morris Date: Wed, 16 Nov 2016 02:46:25 +0000 Subject: [PATCH] allow 100 in flight messages --- aaisp-to-mqtt.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/aaisp-to-mqtt.py b/aaisp-to-mqtt.py index 2735325..11640ee 100755 --- a/aaisp-to-mqtt.py +++ b/aaisp-to-mqtt.py @@ -4,6 +4,7 @@ import sys import logging import json import urllib +import time import configparser import paho.mqtt.client as mqtt import humanfriendly @@ -69,6 +70,7 @@ def main(): # do auth? if mqtt_username is not None and mqtt_password is not None: client.username_pw_set(mqtt_username, mqtt_password) + client.max_inflight_messages_set(100) client.connect(mqtt_broker, mqtt_port, 60) LOG.info("Connected OK to MQTT") @@ -97,7 +99,7 @@ def publish_per_circuit(client, circuit, mqtt_topic_prefix): up = float(circuit["rx_rate"]) up_mb = round(up / 1000000, 2) down = float(circuit["tx_rate"]) - down_mb = round(up / 1000000, 2) + down_mb = round(down / 1000000, 2) # line_prefix = "%s/line/%s" % (mqtt_topic_prefix, circuit["ID"]) login_prefix = "%s/login/%s" % (mqtt_topic_prefix, circuit["login"]) @@ -122,6 +124,7 @@ def publish_per_circuit(client, circuit, mqtt_topic_prefix): return def publish(client, topic, payload): + time.sleep(0.1) result = client.publish(topic=topic, payload=payload, qos=1) if result[0] != 0: LOG.fail("MQTT publish failure: %s %s" , topic, payload)