diff --git a/tests/test_broker.py b/tests/test_broker.py index 0d93c70..44bf269 100644 --- a/tests/test_broker.py +++ b/tests/test_broker.py @@ -39,7 +39,7 @@ test_config = { 'listeners': { 'default': { 'type': 'tcp', - 'bind': 'localhost:1883', + 'bind': '127.0.0.1:1883', 'max_connections': 10 }, }, @@ -102,7 +102,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) client = MQTTClient() - ret = yield from client.connect('mqtt://localhost/') + ret = yield from client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) self.assertIn(client.session.client_id, broker._sessions) yield from client.disconnect() @@ -133,7 +133,7 @@ class BrokerTest(unittest.TestCase): self.assertTrue(broker.transitions.is_started()) conn_reader, conn_writer = \ - yield from asyncio.open_connection('localhost', 1883, loop=self.loop) + yield from asyncio.open_connection('127.0.0.1', 1883, loop=self.loop) reader = StreamReaderAdapter(conn_reader) writer = StreamWriterAdapter(conn_writer) @@ -181,7 +181,7 @@ class BrokerTest(unittest.TestCase): client = MQTTClient(client_id="", config={'auto_reconnect': False}) return_code = None try: - yield from client.connect('mqtt://localhost/', cleansession=False) + yield from client.connect('mqtt://127.0.0.1/', cleansession=False) except ConnectException as ce: return_code = ce.return_code self.assertEqual(return_code, 0x02) @@ -207,7 +207,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) client = MQTTClient() - ret = yield from client.connect('mqtt://localhost/') + ret = yield from client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) yield from client.subscribe([('/topic', QOS_0)]) @@ -245,7 +245,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) client = MQTTClient() - ret = yield from client.connect('mqtt://localhost/') + ret = yield from client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) yield from client.subscribe([('/topic', QOS_0)]) @@ -289,7 +289,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) client = MQTTClient() - ret = yield from client.connect('mqtt://localhost/') + ret = yield from client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) yield from client.subscribe([('/topic', QOS_0)]) @@ -335,7 +335,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) pub_client = MQTTClient() - ret = yield from pub_client.connect('mqtt://localhost/') + ret = yield from pub_client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) ret_message = yield from pub_client.publish('/topic', b'data', QOS_0) @@ -370,7 +370,7 @@ class BrokerTest(unittest.TestCase): self.assertTrue(broker.transitions.is_started()) conn_reader, conn_writer = \ - yield from asyncio.open_connection('localhost', 1883, loop=self.loop) + yield from asyncio.open_connection('127.0.0.1', 1883, loop=self.loop) reader = StreamReaderAdapter(conn_reader) writer = StreamWriterAdapter(conn_writer) @@ -421,7 +421,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) pub_client = MQTTClient() - ret = yield from pub_client.connect('mqtt://localhost/') + ret = yield from pub_client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) yield from pub_client.publish('/+', b'data', QOS_0) @@ -449,7 +449,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) pub_client = MQTTClient() - ret = yield from pub_client.connect('mqtt://localhost/') + ret = yield from pub_client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) ret_message = yield from pub_client.publish('/topic', bytearray(b'\x99' * 256 * 1024), QOS_2) @@ -484,7 +484,7 @@ class BrokerTest(unittest.TestCase): self.assertTrue(broker.transitions.is_started()) pub_client = MQTTClient() - ret = yield from pub_client.connect('mqtt://localhost/') + ret = yield from pub_client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) yield from pub_client.publish('/topic', b'data', QOS_0, retain=True) yield from pub_client.disconnect() @@ -516,7 +516,7 @@ class BrokerTest(unittest.TestCase): self.assertTrue(broker.transitions.is_started()) pub_client = MQTTClient() - ret = yield from pub_client.connect('mqtt://localhost/') + ret = yield from pub_client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) yield from pub_client.publish('/topic', b'', QOS_0, retain=True) yield from pub_client.disconnect() @@ -542,7 +542,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) sub_client = MQTTClient() - yield from sub_client.connect('mqtt://localhost') + yield from sub_client.connect('mqtt://127.0.0.1') ret = yield from sub_client.subscribe([('/qos0', QOS_0), ('/qos1', QOS_1), ('/qos2', QOS_2)]) self.assertEqual(ret, [QOS_0, QOS_1, QOS_2]) @@ -578,7 +578,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) sub_client = MQTTClient() - yield from sub_client.connect('mqtt://localhost') + yield from sub_client.connect('mqtt://127.0.0.1') ret = yield from sub_client.subscribe( [('+', QOS_0), ('+/tennis/#', QOS_0), ('sport+', QOS_0), ('sport/+/player1', QOS_0)]) self.assertEqual(ret, [QOS_0, QOS_0, 0x80, QOS_0]) @@ -606,7 +606,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) sub_client = MQTTClient() - yield from sub_client.connect('mqtt://localhost') + yield from sub_client.connect('mqtt://127.0.0.1') ret = yield from sub_client.subscribe([('#', QOS_0)]) self.assertEqual(ret, [QOS_0]) @@ -644,7 +644,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) sub_client = MQTTClient() - yield from sub_client.connect('mqtt://localhost') + yield from sub_client.connect('mqtt://127.0.0.1') ret = yield from sub_client.subscribe([('+/monitor/Clients', QOS_0)]) self.assertEqual(ret, [QOS_0]) @@ -682,7 +682,7 @@ class BrokerTest(unittest.TestCase): yield from broker.start() self.assertTrue(broker.transitions.is_started()) sub_client = MQTTClient() - yield from sub_client.connect('mqtt://localhost', cleansession=False) + yield from sub_client.connect('mqtt://127.0.0.1', cleansession=False) ret = yield from sub_client.subscribe([('/qos0', QOS_0), ('/qos1', QOS_1), ('/qos2', QOS_2)]) self.assertEqual(ret, [QOS_0, QOS_1, QOS_2]) yield from sub_client.disconnect() @@ -716,7 +716,7 @@ class BrokerTest(unittest.TestCase): @asyncio.coroutine def _client_publish(self, topic, data, qos, retain=False): pub_client = MQTTClient() - ret = yield from pub_client.connect('mqtt://localhost/') + ret = yield from pub_client.connect('mqtt://127.0.0.1/') self.assertEqual(ret, 0) ret = yield from pub_client.publish(topic, data, qos, retain) yield from pub_client.disconnect() diff --git a/tests/test_client.py b/tests/test_client.py index 978f8a0..9f028a7 100644 --- a/tests/test_client.py +++ b/tests/test_client.py @@ -17,17 +17,17 @@ broker_config = { 'listeners': { 'default': { 'type': 'tcp', - 'bind': 'localhost:1883', + 'bind': '127.0.0.1:1883', 'max_connections': 10 }, 'ws': { 'type': 'ws', - 'bind': 'localhost:8080', + 'bind': '127.0.0.1:8080', 'max_connections': 10 }, 'wss': { 'type': 'ws', - 'bind': 'localhost:8081', + 'bind': '127.0.0.1:8081', 'max_connections': 10 }, }, @@ -87,7 +87,7 @@ class MQTTClientTest(unittest.TestCase): try: config = {'auto_reconnect': False} client = MQTTClient(config=config) - yield from client.connect('mqtt://localhost/') + yield from client.connect('mqtt://127.0.0.1/') except ConnectException as e: future.set_result(True) @@ -103,7 +103,7 @@ class MQTTClientTest(unittest.TestCase): broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") yield from broker.start() client = MQTTClient() - yield from client.connect('ws://localhost:8080/') + yield from client.connect('ws://127.0.0.1:8080/') self.assertIsNotNone(client.session) yield from client.disconnect() yield from broker.shutdown() @@ -124,7 +124,7 @@ class MQTTClientTest(unittest.TestCase): yield from broker.start() client = MQTTClient() ca = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'mosquitto.org.crt') - yield from client.connect('ws://localhost:8081/', cafile=ca) + yield from client.connect('ws://127.0.0.1:8081/', cafile=ca) self.assertIsNotNone(client.session) yield from client.disconnect() yield from broker.shutdown() @@ -144,7 +144,7 @@ class MQTTClientTest(unittest.TestCase): broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") yield from broker.start() client = MQTTClient() - yield from client.connect('mqtt://localhost/') + yield from client.connect('mqtt://127.0.0.1/') self.assertIsNotNone(client.session) yield from client.ping() yield from client.disconnect() @@ -165,7 +165,7 @@ class MQTTClientTest(unittest.TestCase): broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") yield from broker.start() client = MQTTClient() - yield from client.connect('mqtt://localhost/') + yield from client.connect('mqtt://127.0.0.1/') self.assertIsNotNone(client.session) ret = yield from client.subscribe([ ('$SYS/broker/uptime', QOS_0), @@ -193,7 +193,7 @@ class MQTTClientTest(unittest.TestCase): broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") yield from broker.start() client = MQTTClient() - yield from client.connect('mqtt://localhost/') + yield from client.connect('mqtt://127.0.0.1/') self.assertIsNotNone(client.session) ret = yield from client.subscribe([ ('$SYS/broker/uptime', QOS_0), @@ -220,14 +220,14 @@ class MQTTClientTest(unittest.TestCase): broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") yield from broker.start() client = MQTTClient() - yield from client.connect('mqtt://localhost/') + yield from client.connect('mqtt://127.0.0.1/') self.assertIsNotNone(client.session) ret = yield from client.subscribe([ ('test_topic', QOS_0), ]) self.assertEqual(ret[0], QOS_0) client_pub = MQTTClient() - yield from client_pub.connect('mqtt://localhost/') + yield from client_pub.connect('mqtt://127.0.0.1/') yield from client_pub.publish('test_topic', data, QOS_0) yield from client_pub.disconnect() message = yield from client.deliver_message() @@ -253,7 +253,7 @@ class MQTTClientTest(unittest.TestCase): broker = Broker(broker_config, plugin_namespace="hbmqtt.test.plugins") yield from broker.start() client = MQTTClient() - yield from client.connect('mqtt://localhost/') + yield from client.connect('mqtt://127.0.0.1/') self.assertIsNotNone(client.session) ret = yield from client.subscribe([ ('test_topic', QOS_0),