async def METHOD_NAME(url):
    async with websockets.METHOD_NAME(url, subprotocols=['json.webpubsub.azure.v1']) as ws:
        eprint(HELP_MESSAGE)
        publisher = Publisher(ws)
        publisher.daemon = True
        publisher.start()
        while True:
            received = await ws.recv()
            print(bcolors.ITALICS + bcolors.OKGREEN + received + bcolors.ENDC + bcolors.ITENDS)