From 22df426087126afa01940a096b394064d2c1383d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl> Date: Fri, 23 Dec 2016 13:31:24 +0100 Subject: [PATCH] final cleanup before addressing #4 --- coolamqp/events.py | 2 +- coolamqp/handler.py | 4 ++-- coolamqp/messages.py | 2 +- coolamqp/orders.py | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/coolamqp/events.py b/coolamqp/events.py index e32db8d..1f42085 100644 --- a/coolamqp/events.py +++ b/coolamqp/events.py @@ -1,4 +1,4 @@ -#coding=UTF-8 +# coding=UTF-8 """ Events emitted by Cluster """ diff --git a/coolamqp/handler.py b/coolamqp/handler.py index 84e5ea7..fd32f62 100644 --- a/coolamqp/handler.py +++ b/coolamqp/handler.py @@ -1,6 +1,6 @@ # coding=UTF-8 import threading -import six.moves.queue as Queue +from six.moves import queue import six import logging import collections @@ -34,7 +34,7 @@ class ClusterHandlerThread(threading.Thread): self.is_terminating = False self.complete_outstanding_upon_termination = False self.order_queue = collections.deque() # queue for inbound orders - self.event_queue = Queue.Queue() # queue for tasks done + self.event_queue = queue.Queue() # queue for tasks done self.connect_id = -1 # connectID of current connection self.declared_exchanges = {} # declared exchanges, by their names diff --git a/coolamqp/messages.py b/coolamqp/messages.py index 74e068a..c1c518f 100644 --- a/coolamqp/messages.py +++ b/coolamqp/messages.py @@ -1,4 +1,4 @@ -#coding=UTF-8 +# coding=UTF-8 import uuid diff --git a/coolamqp/orders.py b/coolamqp/orders.py index ca2bdee..53cbb65 100644 --- a/coolamqp/orders.py +++ b/coolamqp/orders.py @@ -1,4 +1,4 @@ -#coding=UTF-8 +# coding=UTF-8 """ Orders that can be dispatched to ClusterHandlerThread """ -- GitLab