diff options
Diffstat (limited to 'contrib/zeromq/test-server.py')
| -rwxr-xr-x | contrib/zeromq/test-server.py | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/contrib/zeromq/test-server.py b/contrib/zeromq/test-server.py index 5767b71fe..c7804d317 100755 --- a/contrib/zeromq/test-server.py +++ b/contrib/zeromq/test-server.py @@ -6,28 +6,28 @@ import storage.Storage class StorageHandler(storage.Storage.Iface): - def __init__(self): - self.value = 0 + def __init__(self): + self.value = 0 - def incr(self, amount): - self.value += amount + def incr(self, amount): + self.value += amount - def get(self): - return self.value + def get(self): + return self.value def main(): - handler = StorageHandler() - processor = storage.Storage.Processor(handler) + handler = StorageHandler() + processor = storage.Storage.Processor(handler) - ctx = zmq.Context() - reqrep_server = TZmqServer.TZmqServer(processor, ctx, "tcp://0.0.0.0:9090", zmq.REP) - oneway_server = TZmqServer.TZmqServer(processor, ctx, "tcp://0.0.0.0:9091", zmq.UPSTREAM) - multiserver = TZmqServer.TZmqMultiServer() - multiserver.servers.append(reqrep_server) - multiserver.servers.append(oneway_server) - multiserver.serveForever() + ctx = zmq.Context() + reqrep_server = TZmqServer.TZmqServer(processor, ctx, "tcp://0.0.0.0:9090", zmq.REP) + oneway_server = TZmqServer.TZmqServer(processor, ctx, "tcp://0.0.0.0:9091", zmq.UPSTREAM) + multiserver = TZmqServer.TZmqMultiServer() + multiserver.servers.append(reqrep_server) + multiserver.servers.append(oneway_server) + multiserver.serveForever() if __name__ == "__main__": - main() + main() |