This commit is contained in:
@@ -25,7 +25,7 @@ class MyListener(stomp.ConnectionListener):
|
|||||||
def on_message(self, frame):
|
def on_message(self, frame):
|
||||||
logger.info("received a message %s", frame.body)
|
logger.info("received a message %s", frame.body)
|
||||||
link = msgspec.json.decode(frame.body, type=Link)
|
link = msgspec.json.decode(frame.body, type=Link)
|
||||||
self.log.info("found link: %s", link.url)
|
logger.info("found link: %s", link.url)
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
|
|||||||
Reference in New Issue
Block a user