Class CompareAndSwapOperation

    • Constructor Detail

      • CompareAndSwapOperation

        public CompareAndSwapOperation​(org.infinispan.client.hotrod.impl.protocol.Codec codec,
                                       org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory,
                                       AtomicInteger topologyId,
                                       Configuration cfg,
                                       String counterName,
                                       long expect,
                                       long update,
                                       CounterConfiguration counterConfiguration)
    • Method Detail

      • executeOperation

        protected void executeOperation​(io.netty.channel.Channel channel)
        Specified by:
        executeOperation in class org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<Long>
      • 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<Long>
      • 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.Channel channel,
                                            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>