|
@@ -57,7 +57,7 @@ class WriterConsumer(Thread):
|
|
|
log.info("%s consumer queue is empty", self._name)
|
|
|
|
|
|
def put(self, method,params):
|
|
|
- self._messages.put((method, params))
|
|
|
+ self._messages.put_nowait((method, params))
|
|
|
|
|
|
def quit(self):
|
|
|
log.debug("%s thread has quit", self._name)
|