org.apache.cxf.clustering
Class RetryStrategy

java.lang.Object
  org.apache.cxf.clustering.AbstractStaticFailoverStrategy
      org.apache.cxf.clustering.SequentialStrategy
          org.apache.cxf.clustering.RetryStrategy

All Implemented Interfaces:

FailoverStrategy

public class RetryStrategy
extends SequentialStrategy

This strategy simply retries the invocation using the same Endpoint (CXF-2036).

Author:

Dennis Kieselhorst

Constructor Summary

RetryStrategy()

Method Summary

List<Endpoint>	getAlternateEndpoints(Exchange exchange) Get the alternate endpoints for this invocation.
int	getMaxNumberOfRetries()
protected <T> T	getNextAlternate(List<T> alternates) Get next alternate endpoint.
void	setMaxNumberOfRetries(int maxNumberOfRetries)
protected boolean	stillTheSameAddress()

Methods inherited from class org.apache.cxf.clustering.AbstractStaticFailoverStrategy

getAlternateAddresses, getDelayBetweenRetries, getEndpoints, selectAlternateAddress, selectAlternateEndpoint, setAlternateAddresses, setDelayBetweenRetries

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryStrategy

public RetryStrategy()

Method Detail

getAlternateEndpoints

public List<Endpoint> getAlternateEndpoints(Exchange exchange)

Description copied from class: AbstractStaticFailoverStrategy

Get the alternate endpoints for this invocation.

Specified by:

getAlternateEndpoints in interface FailoverStrategy

Overrides:

getAlternateEndpoints in class AbstractStaticFailoverStrategy

Parameters:

exchange - the current Exchange

Returns:

a List of alternate endpoints if available

getNextAlternate

protected <T> T getNextAlternate(List<T> alternates)

Description copied from class: SequentialStrategy

Get next alternate endpoint.

Overrides:

getNextAlternate in class SequentialStrategy

Parameters:

alternates - non-empty List of alternate endpoints

Returns:

stillTheSameAddress

protected boolean stillTheSameAddress()

setMaxNumberOfRetries

public void setMaxNumberOfRetries(int maxNumberOfRetries)

getMaxNumberOfRetries

public int getMaxNumberOfRetries()