Class RetryOnFailureOperation<T>

    • Field Detail

      • log

        protected static final Log log
      • trace

        protected static final boolean trace
    • Method Detail

      • invoke

        public void invoke​(io.netty.channel.Channel channel)
        Description copied from interface: ChannelOperation
        Invoked on an active channel ready to be written
        Specified by:
        invoke in interface ChannelOperation
      • reset

        protected void reset()
      • logAndRetryOrFail

        protected void logAndRetryOrFail​(Throwable e,
                                         boolean canSwitchCluster)
      • fetchChannelAndInvoke

        protected void fetchChannelAndInvoke​(int retryCount,
                                             Set<SocketAddress> failedServers)
      • executeOperation

        protected abstract void executeOperation​(io.netty.channel.Channel channel)