org.infinispan.client.hotrod.impl.operations

Class RetryOnFailureOperation<T>

java.lang.Object

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

org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation<T>

All Implemented Interfaces:

HotRodConstants

Direct Known Subclasses:

AbstractKeyOperation, AddClientListenerOperation, BulkGetKeysOperation, BulkGetOperation, ClearOperation, ExecuteOperation, FaultTolerantPingOperation, GetAllOperation, IterationStartOperation, PutAllOperation, QueryOperation, SizeOperation, StatsOperation

@Immutable
public abstract class RetryOnFailureOperation<T>
extends HotRodOperation

Base class for all the operations that need retry logic: if the operation fails due to connection problems, try with another available connection.

Since:

4.1

Author:

Mircea.Markus@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
protected TransportFactory	transportFactory

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

cacheName, cfg, codec, flags, topologyId

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

ADD_CLIENT_LISTENER_REQUEST, ADD_CLIENT_LISTENER_RESPONSE, AUTH_MECH_LIST_REQUEST, AUTH_MECH_LIST_RESPONSE, AUTH_REQUEST, AUTH_RESPONSE, BULK_GET_KEYS_REQUEST, BULK_GET_KEYS_RESPONSE, BULK_GET_REQUEST, BULK_GET_RESPONSE, CACHE_ENTRY_CREATED_EVENT_RESPONSE, CACHE_ENTRY_EXPIRED_EVENT_RESPONSE, CACHE_ENTRY_MODIFIED_EVENT_RESPONSE, CACHE_ENTRY_REMOVED_EVENT_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, DEFAULT_CACHE_TOPOLOGY, ERROR_RESPONSE, EXEC_REQUEST, EXEC_RESPONSE, GET_ALL_REQUEST, GET_ALL_RESPONSE, GET_REQUEST, GET_RESPONSE, GET_WITH_METADATA, GET_WITH_METADATA_RESPONSE, GET_WITH_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, ILLEGAL_LIFECYCLE_STATE, INFINITE_LIFESPAN, INFINITE_MAXIDLE, INVALID_ITERATION, INVALID_MAGIC_OR_MESSAGE_ID_STATUS, ITERATION_END_REQUEST, ITERATION_END_RESPONSE, ITERATION_NEXT_REQUEST, ITERATION_NEXT_RESPONSE, ITERATION_START_REQUEST, ITERATION_START_RESPONSE, KEY_DOES_NOT_EXIST_STATUS, NO_ERROR_STATUS, NO_ERROR_STATUS_COMPAT, NODE_SUSPECTED, NOT_EXECUTED_WITH_PREVIOUS, NOT_EXECUTED_WITH_PREVIOUS_COMPAT, NOT_PUT_REMOVED_REPLACED_STATUS, PING_REQUEST, PING_RESPONSE, PUT_ALL_REQUEST, PUT_ALL_RESPONSE, PUT_IF_ABSENT_REQUEST, PUT_IF_ABSENT_RESPONSE, PUT_REQUEST, PUT_RESPONSE, QUERY_REQUEST, QUERY_RESPONSE, REMOVE_CLIENT_LISTENER_REQUEST, REMOVE_CLIENT_LISTENER_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, SIZE_REQUEST, SIZE_RESPONSE, STATS_REQUEST, STATS_RESPONSE, SUCCESS_WITH_PREVIOUS, SUCCESS_WITH_PREVIOUS_COMPAT, SWITCH_CLUSTER_TOPOLOGY, UNKNOWN_COMMAND_STATUS, UNKNOWN_VERSION_STATUS, VERSION_10, VERSION_11, VERSION_12, VERSION_13, VERSION_20, VERSION_21, VERSION_22, VERSION_23, VERSION_24, VERSION_25

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RetryOnFailureOperation(Codec codec, TransportFactory transportFactory, byte[] cacheName, AtomicInteger topologyId, int flags, Configuration cfg)

Method Summary

Modifier and Type	Method and Description
T	execute()
protected abstract T	executeOperation(Transport transport)
protected abstract Transport	getTransport(int retryCount, Set<SocketAddress> failedServers)
protected void	logErrorAndThrowExceptionIfNeeded(int i, HotRodClientException e)
protected int	logTransportErrorAndThrowExceptionIfNeeded(int i, String failedClusterName, HotRodClientException e)
protected void	releaseTransport(Transport transport)
protected boolean	shouldRetry(int retryCount)

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

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

hasCompatibility, hasPrevious, isInvalidIteration, isNotExecuted, isNotExist, isSuccess

Field Detail

transportFactory

protected final TransportFactory transportFactory

Constructor Detail

RetryOnFailureOperation

protected RetryOnFailureOperation(Codec codec,
                                  TransportFactory transportFactory,
                                  byte[] cacheName,
                                  AtomicInteger topologyId,
                                  int flags,
                                  Configuration cfg)

Method Detail

execute

public T execute()

Specified by:

execute in class HotRodOperation

shouldRetry

protected boolean shouldRetry(int retryCount)

logTransportErrorAndThrowExceptionIfNeeded

protected int logTransportErrorAndThrowExceptionIfNeeded(int i,
                                                         String failedClusterName,
                                                         HotRodClientException e)

logErrorAndThrowExceptionIfNeeded

protected void logErrorAndThrowExceptionIfNeeded(int i,
                                                 HotRodClientException e)

releaseTransport

protected void releaseTransport(Transport transport)

getTransport

protected abstract Transport getTransport(int retryCount,
                                          Set<SocketAddress> failedServers)

executeOperation

protected abstract T executeOperation(Transport transport)