INNER CODE UNIT · Python

connect_and_subscribe

zapek/Xeres · scripts/bot/bot.py:167

def connect_and_subscribe(conn):
	conn.connect(wait=True, with_connect_command=True)
	conn.subscribe(destination='/topic/chat/private', id=1, ack='auto')
	conn.subscribe(destination='/topic/chat/room', id=2, ack='auto')


class StompListener(stomp.ConnectionListener):
	def __init__(self, conn, own_id):
		self.conn = conn
		self.own_id = own_id

	def on_error(self, frame):
		print('received an error "%s"' % frame.body)

	def on_message(self, frame):
		# print(f'frame is {frame}')
		headers = frame.headers
		data = json.loads(frame.body)

View source record →