- ClientActorBehavior<T> reconnectConnection(final ClientActorBehavior<T> current) {
- // Intentional no-op
- LOG.debug("Skipping reconnect of already-reconnecting connection {}", this);
+ ClientActorBehavior<T> lockedReconnect(final ClientActorBehavior<T> current, final RequestException cause) {
+ this.cause = Preconditions.checkNotNull(cause);
+ LOG.warn("Skipping reconnect of already-reconnecting connection {}", this);