private void retryTransfer(final PipeDeleteDataNodeEvent deleteDataNodeEvent) {
    try {
      if (transferDeletion(deleteDataNodeEvent)) {
        deleteDataNodeEvent.decreaseReferenceCount(
            PipeConsensusAsyncConnector.class.getName(), false);
      } else {
        addFailureEventToRetryQueue(deleteDataNodeEvent);
      }
    } catch (final Exception e) {
      deleteDataNodeEvent.decreaseReferenceCount(
          PipeConsensusAsyncConnector.class.getName(), false);
      addFailureEventToRetryQueue(deleteDataNodeEvent);
    }
  }
Transfer queued {@link Event}s which are waiting for retry.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java