GigaSpaces XAP 10.0.1 API

org.openspaces.grid.gsm.strategy
Class ElasticMachineProvisioningDiscoveredMachinesCache

java.lang.Object
  extended by 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
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
 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

GigaSpaces XAP 10.0.1 API

Copyright © GigaSpaces.