diff --git a/src/tests/queue.py b/src/tests/queue.py index cc5b14ea..71863b54 100644 --- a/src/tests/queue.py +++ b/src/tests/queue.py @@ -18,6 +18,7 @@ class ObjQueue(object): } def __init__(self, tag=b'obj'): + self.curSize = 0 context = zmq.Context() self.socket = context.socket(zmq.SUB) self.socket.connect('tcp://localhost:5556')