diff options
author | Ebus-at-dockstar <ebus@dockstar> | 2013-03-25 10:24:28 +0100 |
---|---|---|
committer | Ebus-at-dockstar <ebus@dockstar> | 2013-03-25 10:24:43 +0100 |
commit | 862282ce99760832d3e9e5b4b1171b861105e004 (patch) | |
tree | 0e229418e391917b79d42a8bdee46fb7a8612895 /datastore/server.py | |
parent | 9522cdffa94f278eb5e1894600535986e22c2890 (diff) | |
download | ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.tar.gz ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.zip |
move old stuff away
Diffstat (limited to 'datastore/server.py')
-rw-r--r-- | datastore/server.py | 36 |
1 files changed, 0 insertions, 36 deletions
diff --git a/datastore/server.py b/datastore/server.py deleted file mode 100644 index 8b9ca4e..0000000 --- a/datastore/server.py +++ /dev/null @@ -1,36 +0,0 @@ -from sys import exit -from stompclient import PublishSubscribeClient -from threading import Thread -from store.controller import MQStoreController -from time import sleep - -import config - -client = PublishSubscribeClient(config.STOMP_HOST, config.STOMP_PORT) -listener = Thread(target=client.listen_forever, name='Frame-Receiver') -listener.start() -client.listening_event.wait() -r = client.connect(config.STOMP_LOGIN, config.STOMP_PASSCODE) -if r.command != "CONNECTED": - print "Failed to connect to {0}:{1}".format(config.STOMP_HOST,config.STOMP_PORT) - print r - exit(1) - - -controller = MQStoreController(client, config.CHANNELS, config.PROCESSORS) -client.subscribe(config.STOMP_QUEUE_PUT, controller.cb_put) -client.subscribe(config.STOMP_QUEUE_GET, controller.cb_get) -client.subscribe(config.STOMP_QUEUE_SUBSCRIBE, controller.cb_subscribe) - -while True: - try: - sleep(1) - except KeyboardInterrupt: - print "shutdown" - try: - client.shutdown_event.set() - except: - pass - exit(0) - - |