|
@@ -28,7 +28,7 @@ class ItemBuffer(threading.Thread):
|
|
|
dedup = None
|
|
|
|
|
|
def __init__(self, redis_key, rabbitmq=None):
|
|
|
- if not hasattr(self, "_table_item"):
|
|
|
+ if not hasattr(self, "_items_queue"):
|
|
|
super(ItemBuffer, self).__init__()
|
|
|
|
|
|
self._thread_stop = False
|