logviewer/eventbus/consumers.py

   1 import json
   2
   3 from channels.generic.websocket import WebsocketConsumer
   4
   5
   6 class EventbusConsumer(WebsocketConsumer):
   7     def connect(self):
   8         self.accept()
   9
  10     def disconnect(self, close_code):
  11         pass
  12
  13     def receive(self, text_data):
  14         print(text_data)
  15         #text_data_json = json.loads(text_data)
  16         #message = text_data_json["message"]
  17
  18         self.send("[]")
  19
  20         #self.send(text_data=json.dumps({"message": message}))