@Override
    public void handleError(Throwable error) {
        this.error = error;
        latch.countDown();
        if (chainedCallback != null) {
            chainedCallback.handleError(error);
        }
    }
Sets an error thrown during RPC execution, and unblocks all threads waiting on {@link #get()}
or {@link #get(long, java.util.concurrent.TimeUnit)}.

@param error the RPC error to set.
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/client/CallFuture.java