- Entry<ActorRef, RequestEnvelope> prepareForTransmit(final Request<?, ?> req) {
- // This is guarded by remoteMaxMessages() == 0
- throw new UnsupportedOperationException("Attempted to transmit on a reconnecting connection");
+ ClientActorBehavior<T> lockedReconnect(final ClientActorBehavior<T> current, final RequestException cause) {
+ this.cause = Preconditions.checkNotNull(cause);
+ LOG.warn("Skipping reconnect of already-reconnecting connection {}", this);
+ return current;