src/main/java/io/axoniq/axonserver/connector/impl/AxonServerManagedChannel.java
/**
     * Requests a dedicated reconnect of this {@link ManagedChannel} implementation.
     */
Requests a dedicated reconnect of this  ManagedChannel implementation.
Requests a dedicated reconnect of this ManagedChannel implementation .
public void requestReconnect() {
        doIfNotNull(this.activeChannel.getAndSet(null), currentChannel -> {
            logger.info("Reconnect for context {} requested. Closing current connection.", context);
            nextAttemptTime.set(0);
            currentChannel.shutdown();
            executor.schedule(currentChannel::shutdownNow, 5, TimeUnit.SECONDS);
        });
    }
public void requestReconnect ( ) { doIfNotNull ( this . activeChannel . getAndSet ( null ) , currentChannel -> { logger . info ( "Reconnect for context {} requested. Closing current connection." , context ) ; nextAttemptTime . set ( 0 ) ; currentChannel . shutdown ( ) ; executor . schedule ( currentChannel :: shutdownNow , 5 , TimeUnit . SECONDS ) ; } ) ; }
Requests a dedicated reconnect of this {@link ManagedChannel} implementation.
Requests a dedicated reconnect of this { @link ManagedChannel } implementation .