org.apache.cxf.clustering
Class AbstractStaticFailoverStrategy

java.lang.Object
  extended by org.apache.cxf.clustering.AbstractStaticFailoverStrategy
All Implemented Interfaces:
FailoverStrategy
Direct Known Subclasses:
RandomStrategy, SequentialStrategy

public abstract class AbstractStaticFailoverStrategy
extends java.lang.Object
implements FailoverStrategy

Failover strategy based on a static cluster represented by multiple endpoints associated with the same service instance.


Constructor Summary
AbstractStaticFailoverStrategy()
           
 
Method Summary
 java.util.List<Endpoint> getAlternateEndpoints(Exchange exchange)
          Get the alternate endpoints for this invocation.
protected  java.util.List<Endpoint> getEndpoints(Exchange exchange, boolean acceptCandidatesWithSameAddress)
          Get the endpoints for this invocation.
protected abstract  Endpoint getNextAlternate(java.util.List<Endpoint> alternates)
          Get next alternate endpoint.
 Endpoint selectAlternateEndpoint(java.util.List<Endpoint> alternates)
          Select one of the alternate endpoints for a retried invocation.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractStaticFailoverStrategy

public AbstractStaticFailoverStrategy()
Method Detail

getAlternateEndpoints

public java.util.List<Endpoint> getAlternateEndpoints(Exchange exchange)
Get the alternate endpoints for this invocation.

Specified by:
getAlternateEndpoints in interface FailoverStrategy
Parameters:
exchange - the current Exchange
Returns:
a List of alternate endpoints if available

getEndpoints

protected java.util.List<Endpoint> getEndpoints(Exchange exchange,
                                                boolean acceptCandidatesWithSameAddress)
Get the endpoints for this invocation.

Parameters:
exchange - the current Exchange
acceptCandidatesWithSameAddress - true to accept candidates with the same address
Returns:
a List of alternate endpoints if available

selectAlternateEndpoint

public Endpoint selectAlternateEndpoint(java.util.List<Endpoint> alternates)
Select one of the alternate endpoints for a retried invocation.

Specified by:
selectAlternateEndpoint in interface FailoverStrategy
Parameters:
a - List of alternate endpoints if available
Returns:
the selected endpoint

getNextAlternate

protected abstract Endpoint getNextAlternate(java.util.List<Endpoint> alternates)
Get next alternate endpoint.

Parameters:
alternates - non-empty List of alternate endpoints
Returns:


Apache CXF