def METHOD_NAME(self, message: bytes) -> None:
    try:
        message_list = [message]
        # TODO: Enable zero copy
        self._producer.send_multipart(message_list)
        print("Message Queued Successfully !")
    except zmq.Again as e:
        # TODO: Add retry mechanism if this error occurs
        raise e
    except zmq.ZMQError as e:
        if e.errno == zmq.ETERM:
            print("Connection Interrupted....")
        else:
            raise e