#encoding:utf-8
import stomp
import sys
import thread
# Create your tests here.
topic_name='/topic/your topic name'
broker_url='your broker ip'
broker_port='your broker port'
listener_name='Samplequeue'
from testapp import models
import threading
class SampleListener(object):
isrecieved = False
def on_error(self,header,message):
print ("%s" % header)
print ("%s" % message)
def on_message(self,headers,message):
print ("%s" % header)
print ("%s" % message)
class Consumer(threading.Thread):
def __init__(self, t_name):
super(Consumer,self).__init__()
self.t_name = t_name
def run(self):
conn = stomp.Connection10([(broker_url,broker_port)])
conn.set_listener(listener_name,SampleListener())
conn.start()
conn.connect()
conn.subscribe(topic_name)
while 1:
pass
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
