code: def received_message(self, message):
      try:
          msg = json.loads(message.data)
  
          if self.__keepAliveMgr is not None:
              self.__keepAliveMgr.setAlive()
              if self.__keepAliveMgr.handleResponse(msg):
                  return
  
          self.onMessage(msg)
      except Exception as e:
          self.onUnhandledException(e)
  
imports: import json
  import time
  import threading
  import six
  from ws4py.client import tornadoclient
  import tornado
  import pyalgotrade.logger
label_desc: Use image node_id 5 for calling the WebSocketClientBase obj's underlying member method code with example usage: obj.received_message(message) without return types