diff --git a/script/test/TestZMQ2.py b/script/test/TestZMQ2.py new file mode 100644 index 0000000..81faff8 --- /dev/null +++ b/script/test/TestZMQ2.py @@ -0,0 +1,35 @@ +from ch.psi.pshell.bs import Stream +from ch.psi.pshell.bs import Provider +from ch.psi.pshell.bs.ProviderConfig import SocketType; + +providers, streams = [], [] +for i in range(9000, 9008) + p = Provider("Provider"+str(i),"tcp://SFTEST-CVME-DBPM1:"+str(i), SocketType.PULL) + p.intialize() + providers.add(p) + s = Stream("Stream"+str(i), p) + s.initialize() + streams.add(s) + + + + +try: + for s in streams: + s.start(True) + s.waitCacheChange(5000) + print s.getName() + " channels:" + str(s.getIdentifiers()) +finally: + try: + for s in streams: + s.close() + except: + pass + + + + + + + +