Class ResetOperation

  • All Implemented Interfaces:
    Runnable, CompletionStage<Void>, Future<Void>, org.infinispan.client.hotrod.impl.protocol.HotRodConstants, org.infinispan.client.hotrod.impl.transport.netty.ChannelOperation

    public class ResetOperation
    extends org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<T>
    A counter operation for StrongCounter.reset() and WeakCounter.reset().
    Since:
    9.2
    Author:
    Pedro Ruivo
    • Constructor Detail

      • ResetOperation

        public ResetOperation​(org.infinispan.client.hotrod.impl.protocol.Codec codec,
                              org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory,
                              AtomicInteger topologyId,
                              Configuration cfg,
                              String counterName,
                              boolean useConsistentHash)
    • Method Detail

      • executeOperation

        protected void executeOperation​(io.netty.channel.Channel channel)
        Specified by:
        executeOperation in class org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<Void>
      • acceptResponse

        public void acceptResponse​(io.netty.buffer.ByteBuf buf,
                                   short status,
                                   org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder decoder)
        Specified by:
        acceptResponse in class org.infinispan.client.hotrod.impl.operations.HotRodOperation<Void>
      • fetchChannelAndInvoke

        protected void fetchChannelAndInvoke​(int retryCount,
                                             Set<SocketAddress> failedServers)
        Overrides:
        fetchChannelAndInvoke in class org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<T>
      • handleException

        protected Throwable handleException​(Throwable cause,
                                            io.netty.channel.ChannelHandlerContext ctx,
                                            SocketAddress address)
        Overrides:
        handleException in class org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<T>
      • addParams

        protected void addParams​(StringBuilder sb)
        Overrides:
        addParams in class org.infinispan.client.hotrod.impl.operations.HotRodOperation<T>