diff --git a/script/test/TestZMQ2.py b/script/test/TestZMQ2.py
index 368b70e..320e225 100644
--- a/script/test/TestZMQ2.py
+++ b/script/test/TestZMQ2.py
@@ -24,10 +24,10 @@ def check(s):
         pid = p
 
 class StreamListener (DeviceListener):
-    def onCacheChanged(self, device, value, former, timestamp, valueChange)
+    def onCacheChanged(self, device, value, former, timestamp, valueChange):
         if self.pid!= (value.pulseId + self.divider):
              print s.getName() + " error: received pid %d, expecting %d" % (value.pulseId, (self.pid+ 1))
-        pid = value.pulseId
+        self.pid = value.pulseId
 
      
 try:
@@ -42,12 +42,16 @@ try:
     parallelize(*args)
     #check(streams[0])
     """
-    "
+    
     for s in streams:
         l = StreamListener()
         l.divider = 3 if s.name == "Stream9000" else 1
         l.pid = s.take().pulseId
-        s.addListener(listenerAI)
+        s.addListener(l)
+        break
+
+    sleep(36000)
+        
                 
 finally:
     try: