org.infinispan.client.hotrod.impl.operations

Class FaultTolerantPingOperation

java.lang.Object

org.infinispan.client.hotrod.impl.operations.HotRodOperation

org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<PingOperation.PingResult>

org.infinispan.client.hotrod.impl.operations.FaultTolerantPingOperation

All Implemented Interfaces:

HotRodConstants

public class FaultTolerantPingOperation
extends RetryOnFailureOperation<PingOperation.PingResult>

A fault tolerant ping operation that can survive to node failures.

Since:

5.2

Author:

Galder Zamarreño

Field Summary

Fields inherited from class org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation

transportFactory

Fields inherited from class org.infinispan.client.hotrod.impl.operations.HotRodOperation

cacheName, codec, flags, topologyId

Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants

BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_RESPONSE, CLEAR_REQUEST, CLEAR_RESPONSE, CLIENT_INTELLIGENCE_BASIC, CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE, CLIENT_INTELLIGENCE_TOPOLOGY_AWARE, COMMAND_TIMEOUT_STATUS, CONTAINS_KEY_REQUEST, CONTAINS_KEY_RESPONSE, DEFAULT_CACHE_NAME_BYTES, ERROR_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, QUERY_REQUEST, QUERY_RESPONSE, REMOVE_IF_UNMODIFIED_REQUEST, REMOVE_IF_UNMODIFIED_RESPONSE, REMOVE_REQUEST, REMOVE_RESPONSE, REPLACE_IF_UNMODIFIED_REQUEST, REPLACE_IF_UNMODIFIED_RESPONSE, REPLACE_REQUEST, REPLACE_RESPONSE, REQUEST_MAGIC, REQUEST_PARSING_ERROR_STATUS, RESPONSE_MAGIC, SERVER_ERROR_STATUS, STATS_REQUEST, STATS_RESPONSE, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FaultTolerantPingOperation(Codec codec, TransportFactory transportFactory, byte[] cacheName, AtomicInteger topologyId, Flag[] flags)

Method Summary

Methods

Modifier and Type	Method and Description
protected PingOperation.PingResult	executeOperation(Transport transport)
protected Transport	getTransport(int retryCount)

Methods inherited from class org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation

execute, logErrorAndThrowExceptionIfNeeded, releaseTransport, shouldRetry

Methods inherited from class org.infinispan.client.hotrod.impl.operations.HotRodOperation

readHeaderAndValidate, writeHeader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FaultTolerantPingOperation

protected FaultTolerantPingOperation(Codec codec,
                          TransportFactory transportFactory,
                          byte[] cacheName,
                          AtomicInteger topologyId,
                          Flag[] flags)

Method Detail

getTransport

protected Transport getTransport(int retryCount)

Specified by:

getTransport in class RetryOnFailureOperation<PingOperation.PingResult>

executeOperation

protected PingOperation.PingResult executeOperation(Transport transport)

Specified by:

executeOperation in class RetryOnFailureOperation<PingOperation.PingResult>