Skip to content
Snippets Groups Projects
Commit 22df4260 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

final cleanup before addressing #4

parent 6797d457
No related branches found
No related tags found
No related merge requests found
#coding=UTF-8 # coding=UTF-8
""" """
Events emitted by Cluster Events emitted by Cluster
""" """
......
# coding=UTF-8 # coding=UTF-8
import threading import threading
import six.moves.queue as Queue from six.moves import queue
import six import six
import logging import logging
import collections import collections
...@@ -34,7 +34,7 @@ class ClusterHandlerThread(threading.Thread): ...@@ -34,7 +34,7 @@ class ClusterHandlerThread(threading.Thread):
self.is_terminating = False self.is_terminating = False
self.complete_outstanding_upon_termination = False self.complete_outstanding_upon_termination = False
self.order_queue = collections.deque() # queue for inbound orders 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.connect_id = -1 # connectID of current connection
self.declared_exchanges = {} # declared exchanges, by their names self.declared_exchanges = {} # declared exchanges, by their names
......
#coding=UTF-8 # coding=UTF-8
import uuid import uuid
......
#coding=UTF-8 # coding=UTF-8
""" """
Orders that can be dispatched to ClusterHandlerThread Orders that can be dispatched to ClusterHandlerThread
""" """
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment