def METHOD_NAME(self):
    server_send_queue = queue.Queue(0)
    # self.server_send_thread = MPISendThread(
    #     self.comm, self.rank, self.size, "ServerSendThread", server_send_queue
    # )
    # self.server_send_thread.start()
    server_receive_queue = queue.Queue(0)
    self.server_receive_thread = MPIReceiveThread(
        self.comm, self.rank, self.size, "ServerReceiveThread", server_receive_queue
    )
    self.server_receive_thread.start()
    return server_send_queue, server_receive_queue