import threading
import select
import multiprocessing
-import queue
+try:
+ import queue as queue
+except ImportError:
+ import Queue as queue
import logging
def callback(self):
raise NotImplemented
- def get_callback(self, async):
+ def get_callback(self, do_async):
return self.callback
def get_msg_index(self, name):