|
@@ -59,7 +59,7 @@ class WriterConsumer(Thread):
|
|
|
|
|
|
def put(self, method, params):
|
|
|
if self._stopped == False:
|
|
|
- self._messages.append((method, params))
|
|
|
+ self._messages.appendleft((method, params))
|
|
|
|
|
|
def quit(self):
|
|
|
log.debug("%s thread has quit", self._name)
|