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, BulkGetOperation, ClearOperation, FaultTolerantPingOperation, 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
Fields inherited from interface org.infinispan.client.hotrod.impl.protocol.HotRodConstants |
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_VERSION, GET_WITH_VERSION_RESPONSE, HOTROD_STRING_CHARSET, 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, 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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
transportFactory
protected final TransportFactory transportFactory
RetryOnFailureOperation
protected RetryOnFailureOperation(Codec codec,
TransportFactory transportFactory,
byte[] cacheName,
AtomicInteger topologyId,
Flag[] flags)
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)
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.