com.gigaspaces.internal.remoting.routing.clustered

Class RoundRobinLoadBalancingStrategy

java.lang.Object

com.gigaspaces.internal.remoting.routing.clustered.SpaceProxyLoadBalancingStrategy

com.gigaspaces.internal.remoting.routing.clustered.RoundRobinLoadBalancingStrategy

public class RoundRobinLoadBalancingStrategy
extends SpaceProxyLoadBalancingStrategy

Since:

9.1.2

Author:

Niv Ingberg

Field Summary

Fields inherited from class com.gigaspaces.internal.remoting.routing.clustered.SpaceProxyLoadBalancingStrategy

_cluster, _lock, _logger

Constructor Summary

Constructors

Constructor and Description
RoundRobinLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster, Collection<String> membersNames, int numOfOperationsTypes)

Method Summary

Modifier and Type	Method and Description
RemoteOperationsExecutorProxy	getCandidate(RemoteOperationRequest<?> request)
void	onMemberConnected(RemoteOperationsExecutorProxy connectedMember)
void	onMemberDisconnected(String disconnectedMemberName)
protected void	updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy) This method MUST be called from within a synchronized block.

Methods inherited from class com.gigaspaces.internal.remoting.routing.clustered.SpaceProxyLoadBalancingStrategy

findActiveMember, findActiveMemberUninterruptibly, findAnyAvailableMember

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinLoadBalancingStrategy

public RoundRobinLoadBalancingStrategy(RemoteOperationsExecutorsCluster cluster,
                                       Collection<String> membersNames,
                                       int numOfOperationsTypes)

Method Detail

getCandidate

public RemoteOperationsExecutorProxy getCandidate(RemoteOperationRequest<?> request)

Specified by:

getCandidate in class SpaceProxyLoadBalancingStrategy

onMemberConnected

public void onMemberConnected(RemoteOperationsExecutorProxy connectedMember)

Overrides:

onMemberConnected in class SpaceProxyLoadBalancingStrategy

onMemberDisconnected

public void onMemberDisconnected(String disconnectedMemberName)

Overrides:

onMemberDisconnected in class SpaceProxyLoadBalancingStrategy

updateActiveProxy

protected void updateActiveProxy(RemoteOperationsExecutorProxy newActiveProxy)

Description copied from class: SpaceProxyLoadBalancingStrategy

This method MUST be called from within a synchronized block.

Specified by:

updateActiveProxy in class SpaceProxyLoadBalancingStrategy