|
@@ -37,22 +37,22 @@ Thread(target=listen_to_redis).start()
|
|
|
|
|
|
# def common_down_data(user_id, data, namespace='/ws/cs-im'):
|
|
|
# emit('common_down_data', data, room=user_id, namespace=namespace)
|
|
|
-def common_down_data(user_id, data, namespace='/ws/cs-im'):
|
|
|
- """推送 common_down_data 消息"""
|
|
|
- # 发布消息到 Redis 频道
|
|
|
- redis_handler.publish('socket_channel', json.dumps({
|
|
|
- 'event': 'common_down_data',
|
|
|
- 'user_id': user_id,
|
|
|
- 'data': data
|
|
|
- }))
|
|
|
-def common_down_cmd(user_id, data):
|
|
|
- """推送 common_down_cmd 消息"""
|
|
|
- # 发布消息到 Redis 频道
|
|
|
- redis_handler.publish('socket_channel', json.dumps({
|
|
|
- 'event': 'common_down_cmd',
|
|
|
- 'user_id': user_id,
|
|
|
- 'data': data
|
|
|
- }))
|
|
|
+# def common_down_data(user_id, data, namespace='/ws/cs-im'):
|
|
|
+# """推送 common_down_data 消息"""
|
|
|
+# # 发布消息到 Redis 频道
|
|
|
+# redis_handler.publish('socket_channel', json.dumps({
|
|
|
+# 'event': 'common_down_data',
|
|
|
+# 'user_id': user_id,
|
|
|
+# 'data': data
|
|
|
+# }))
|
|
|
+# def common_down_cmd(user_id, data):
|
|
|
+# """推送 common_down_cmd 消息"""
|
|
|
+# # 发布消息到 Redis 频道
|
|
|
+# redis_handler.publish('socket_channel', json.dumps({
|
|
|
+# 'event': 'common_down_cmd',
|
|
|
+# 'user_id': user_id,
|
|
|
+# 'data': data
|
|
|
+# }))
|
|
|
|
|
|
# def common_down_cmd(user_id, data):
|
|
|
# emit('common_down_cmd', data, room=user_id)
|