Package org.openspaces.admin.pu.dependency.config

Class ProcessingUnitDependencyConfig

java.lang.Object
org.openspaces.admin.pu.dependency.config.ProcessingUnitDependencyConfig
All Implemented Interfaces:
InternalProcessingUnitDependency, ProcessingUnitDependency
public class ProcessingUnitDependencyConfig extends Object implements InternalProcessingUnitDependency
Since:
9.0.1
Author:
itaif

  • Constructor Details

    • ProcessingUnitDependencyConfig

      public ProcessingUnitDependencyConfig()
      For spring injection

  • Method Details

    • getWaitForDeploymentToComplete

      public boolean getWaitForDeploymentToComplete()
      Specified by:
      getWaitForDeploymentToComplete in interface ProcessingUnitDependency
      Returns:
      true if the dependent processing unit waits until the required processing unit deployment is complete. False indicates this dependency is disabled.

    • setWaitForDeploymentToComplete

      public void setWaitForDeploymentToComplete(boolean waitForDeploymentToComplete)
      Description copied from interface: InternalProcessingUnitDependency
      When true the dependant processing unit waits until the required processing unit completes deployment. The deployment is considered complete when it's status is INTACT, and in case it is an Elastic Processing Unit then it also means scale is not in progress. When false this dependency is disabled
      Specified by:
      setWaitForDeploymentToComplete in interface InternalProcessingUnitDependency

    • getMinimumNumberOfDeployedInstancesPerPartition

      public int getMinimumNumberOfDeployedInstancesPerPartition()
      Specified by:
      getMinimumNumberOfDeployedInstancesPerPartition in interface ProcessingUnitDependency
      Returns:
      the number of required processing unit instances per partition that the dependent processing unit waits for. Zero indicates this dependency is disabled.

    • setMinimumNumberOfDeployedInstancesPerPartition

      public void setMinimumNumberOfDeployedInstancesPerPartition(int minimumNumberOfDeployedInstancesPerPartition)
      Description copied from interface: InternalProcessingUnitDependency
      When bigger than 0 the dependant processing unit waits until the required processing unit has at least the specified number of instances per partition. 1 means at least one instance per partition (each partition has at least one primary instance) 2 means at least two instances per partition (each partition has at least one primary instance and one backup instance) When 0 this dependency is disabled
      Specified by:
      setMinimumNumberOfDeployedInstancesPerPartition in interface InternalProcessingUnitDependency

    • getMinimumNumberOfDeployedInstances

      public int getMinimumNumberOfDeployedInstances()
      Specified by:
      getMinimumNumberOfDeployedInstances in interface ProcessingUnitDependency
      Returns:
      the number of required processing unit instances that the dependent processing unit waits for. Zero indicates this dependency is disabled.

    • setMinimumNumberOfDeployedInstances

      public void setMinimumNumberOfDeployedInstances(int minimumNumberOfDeployedInstances)
      Description copied from interface: InternalProcessingUnitDependency
      When bigger than 0 the dependant processing unit waits until the required processing unit has at least the specified number of instances. When 0 this dependency is disabled
      Specified by:
      setMinimumNumberOfDeployedInstances in interface InternalProcessingUnitDependency

    • getRequiredProcessingUnitName

      public String getRequiredProcessingUnitName()
      Specified by:
      getRequiredProcessingUnitName in interface ProcessingUnitDependency
      Returns:
      the name of the required processing unit (the processing unit that is being dependent-upon)

    • setRequiredProcessingUnitName

      public void setRequiredProcessingUnitName(String requiredProcessingUnitName)

    • afterPropertiesSet

      @PostConstruct public void afterPropertiesSet()

    • mergeDependency

      public void mergeDependency(ProcessingUnitDependency otherDependency)
      Description copied from interface: InternalProcessingUnitDependency
      Merges the specified dependencies with existing dependencies.
      Specified by:
      mergeDependency in interface InternalProcessingUnitDependency

    • mergeDependency

      public void mergeDependency(org.jini.rio.core.RequiredDependency otherRequiredDependency)
      Description copied from interface: InternalProcessingUnitDependency
      Merges the specified dependencies (received from the GSM) with existing dependencies.
      Specified by:
      mergeDependency in interface InternalProcessingUnitDependency

    • toRequiredDependency

      public org.jini.rio.core.RequiredDependency toRequiredDependency()
      Description copied from interface: InternalProcessingUnitDependency
      Converts this to the GSM implementation equivalent
      Specified by:
      toRequiredDependency in interface InternalProcessingUnitDependency

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object