diff options
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() |