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, BulkGetKeysOperation, BulkGetOperation, ClearOperation, FaultTolerantPingOperation, QueryOperation, 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, 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	RetryOnFailureOperation(Codec codec, TransportFactory transportFactory, byte[] cacheName, AtomicInteger topologyId, Flag[] flags)

Method Summary

Methods

Modifier and Type	Method and Description
T	execute()
protected abstract T	executeOperation(Transport transport)
protected abstract Transport	getTransport(int retryCount)
protected void	logErrorAndThrowExceptionIfNeeded(int i, 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

Field Detail

transportFactory

protected final TransportFactory transportFactory

Constructor Detail

RetryOnFailureOperation

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

Method Detail

execute

public T execute()

Specified by:

execute in class HotRodOperation

shouldRetry

protected boolean shouldRetry(int retryCount)

logErrorAndThrowExceptionIfNeeded

protected void logErrorAndThrowExceptionIfNeeded(int i,
                                     HotRodClientException e)

releaseTransport

protected void releaseTransport(Transport transport)

getTransport

protected abstract Transport getTransport(int retryCount)

executeOperation

protected abstract T executeOperation(Transport transport)