summaryrefslogtreecommitdiff
path: root/datastore/dump.py
diff options
context:
space:
mode:
Diffstat (limited to 'datastore/dump.py')
-rw-r--r--datastore/dump.py29
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()