code: async def websocket_send(self, message, stream_name):
          
          text = message.get("text")
          # todo what to do on binary!
          json = await self.decode_json(text)
          data = {
              "stream": stream_name,
              "payload": json
          }
          await self.send_json(data)
docs: Capture downstream websocket.send messages from the upstream applications.