diff --git a/st2common/st2common/transport/publishers.py b/st2common/st2common/transport/publishers.py index ddf5d2f8c9..73596ed70e 100644 --- a/st2common/st2common/transport/publishers.py +++ b/st2common/st2common/transport/publishers.py @@ -43,8 +43,8 @@ class PoolPublisher(object): def __init__(self, urls=None): """ - :param urls: Connection URLs to use. If not provided it uses a default value from th - config. + :param urls: Connection URLs to use. If not provided it uses a default value from + the config. :type urls: ``list`` """ urls = urls or transport_utils.get_messaging_urls() @@ -67,7 +67,7 @@ def publish(self, payload, exchange, routing_key="", compression=None): ) def do_publish(connection, channel): - # ProducerPool ends up creating it own ConnectionPool which ends up + # ProducerPool ends up creating its own ConnectionPool which ends up # completely invalidating this ConnectionPool. Also, a ConnectionPool for # producer does not really solve any problems for us so better to create a # Producer for each publish. diff --git a/st2common/tests/unit/test_transport.py b/st2common/tests/unit/test_transport.py index ae12b1ea9d..4e613716b8 100644 --- a/st2common/tests/unit/test_transport.py +++ b/st2common/tests/unit/test_transport.py @@ -97,9 +97,6 @@ def test_publish_compression(self): self.assertEqual( watcher.received_messages[0][1].properties["content_encoding"], "binary" ) - self.assertEqual( - watcher.received_messages[0][1].properties["application_headers"], {} - ) self.assertEqual(watcher.received_messages[0][0].id, live_action_db.id) # 2. Verify config level option is used