async def websocket_send(self, message, stream_name):
text = message.get("<STR_LIT:text>")<EOL>json = await self.decode_json(text)<EOL>data = {<EOL>"<STR_LIT>": stream_name,<EOL>"<STR_LIT>": json<EOL>}<EOL>await self.send_json(data)<EOL>
Capture downstream websocket.send messages from the upstream applications.