import asyncio, queue
message_queue = asyncio.Queue()
websocket_manager = None
websocket = None

# def sendSocketMessage(data):
#         payload = data
#         loop = asyncio.get_event_loop()
#         if websocket_manager == None:
#             loop.create_task(message_queue.put(payload))
#         else:
#             async def _do_send():
#                 await websocket_manager.send_personal_message(payload, websocket_manager)
#             loop.create_task(_do_send())
#         print("\033[1;32;40m common===>sendSocketMessage \033[0m", data)