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