code: def _process_message(self, message):
      if message.get_type() == MessageType.STOP:
          self._experiment.stop()
          self._abort()
      elif message.get_type() == MessageType.ABORT:
          self._experiment.stop("Remotely aborted")
          self._abort()
  
file_path: neptune-client/src/neptune/legacy/internal/threads/aborting_thread.py
imports: import threading
  from websocket import WebSocketConnectionClosedException
  from neptune.legacy.internal.threads.neptune_thread import NeptuneThread
  from neptune.legacy.internal.websockets.message import MessageType
  from neptune.legacy.internal.websockets.websocket_message_processor import WebsocketMessageProcessor
label_desc: Use image node_id 2 for calling the AbortMessageProcessor obj's underlying member method code with example usage: obj._process_message(message) without return types