|
|
@ -87,6 +87,7 @@ class WebSocketAdapter: |
|
|
try: |
|
|
try: |
|
|
# 从Channel接收消息 |
|
|
# 从Channel接收消息 |
|
|
msg = await self.outbound_channel.receive_message(timeout=0.5) |
|
|
msg = await self.outbound_channel.receive_message(timeout=0.5) |
|
|
|
|
|
logger.debug(f"适配器接收消息: {self.outbound_channel.name} -> msg: {msg}") |
|
|
if msg: |
|
|
if msg: |
|
|
# 将消息数据序列化为JSON字符串 |
|
|
# 将消息数据序列化为JSON字符串 |
|
|
import json |
|
|
import json |
|
|
|