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/dump.py | |
parent | 9522cdffa94f278eb5e1894600535986e22c2890 (diff) | |
download | ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.tar.gz ebus-alt-862282ce99760832d3e9e5b4b1171b861105e004.zip |
move old stuff away
Diffstat (limited to 'datastore/dump.py')
-rw-r--r-- | datastore/dump.py | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/datastore/dump.py b/datastore/dump.py deleted file mode 100644 index ac7ec29..0000000 --- a/datastore/dump.py +++ /dev/null @@ -1,29 +0,0 @@ -from time import sleep -from stompclient import PublishSubscribeClient -import config -from threading import Thread -from pprint import pprint - -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 not client.connection: - print r - exit(1) - - -def dump(x): - pprint(x.headers) - for line in x.body.split("\n"): - print "\t", - pprint(line) - -client.subscribe("/queue/queue-new", dump) - -try: - while True: - sleep(1) -except: - client.disconnect() |