org.openspaces.grid.gsm.strategy

Class ElasticMachineProvisioningDiscoveredMachinesCache

java.lang.Object

org.openspaces.grid.gsm.strategy.ElasticMachineProvisioningDiscoveredMachinesCache

All Implemented Interfaces:

Runnable, AdminEventListener, GridServiceAgentAddedEventListener, GridServiceAgentRemovedEventListener, DiscoveredMachinesCache

public class ElasticMachineProvisioningDiscoveredMachinesCache
extends Object
implements DiscoveredMachinesCache, GridServiceAgentAddedEventListener, GridServiceAgentRemovedEventListener, Runnable

Constructor Summary

Constructors

Constructor and Description
ElasticMachineProvisioningDiscoveredMachinesCache(ProcessingUnit pu, NonBlockingElasticMachineProvisioning machineProvisioning, boolean quiteMode, long pollingIntervalSeconds) Quite mode fall backs to the admin API (lookup discovery) in case of exceptions from the machine provisioning

Method Summary

Modifier and Type	Method and Description
void	destroy()
Collection<GridServiceAgent>	getDiscoveredAgents()
void	gridServiceAgentAdded(GridServiceAgent gridServiceAgent) Called when a grid service is added.
void	gridServiceAgentRemoved(GridServiceAgent gridServiceAgent) Called when a grid service is removed.
void	run() Synchronizes the list of agents with the machine provisioning bean We use the syncAgents flag to make sure there is no more than one concurrent call to machineProvisioning

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticMachineProvisioningDiscoveredMachinesCache

public ElasticMachineProvisioningDiscoveredMachinesCache(ProcessingUnit pu,
                                                         NonBlockingElasticMachineProvisioning machineProvisioning,
                                                         boolean quiteMode,
                                                         long pollingIntervalSeconds)

Quite mode fall backs to the admin API (lookup discovery) in case of exceptions from the machine provisioning

Method Detail

destroy

public void destroy()

getDiscoveredAgents

public Collection<GridServiceAgent> getDiscoveredAgents()
                                                 throws WaitingForDiscoveredMachinesException,
                                                        FailedToDiscoverMachinesException

Specified by:

getDiscoveredAgents in interface DiscoveredMachinesCache

Throws:

WaitingForDiscoveredMachinesException

FailedToDiscoverMachinesException

gridServiceAgentRemoved

public void gridServiceAgentRemoved(GridServiceAgent gridServiceAgent)

Description copied from interface: GridServiceAgentRemovedEventListener

Called when a grid service is removed.

Specified by:

gridServiceAgentRemoved in interface GridServiceAgentRemovedEventListener

gridServiceAgentAdded

public void gridServiceAgentAdded(GridServiceAgent gridServiceAgent)

Description copied from interface: GridServiceAgentAddedEventListener

Called when a grid service is added.

Specified by:

gridServiceAgentAdded in interface GridServiceAgentAddedEventListener

run

public void run()

Synchronizes the list of agents with the machine provisioning bean We use the syncAgents flag to make sure there is no more than one concurrent call to machineProvisioning

Specified by:

run in interface Runnable