def METHOD_NAME(self):
    try:
        message_list = self._consumer.recv_multipart()
        message = message_list[0]
        print("Message Received Successfully !")
    except zmq.ZMQError as e:
        if e.errno == zmq.ETERM:
            print("Subscriber connection Terminated")
        else:
            raise e
    self.message_handler.handle_message(message=message)