org.openspaces.admin.internal.application

Class DefaultApplication

java.lang.Object

org.openspaces.admin.internal.application.DefaultApplication

All Implemented Interfaces:

Application, InternalApplication

public class DefaultApplication
extends Object
implements InternalApplication

Constructor Summary

Constructors

Constructor and Description
DefaultApplication(InternalAdmin admin, String name)

Method Summary

Modifier and Type	Method and Description
ProcessingUnit	deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment) Deploys the specified processing unit adding it to this application
ProcessingUnit	deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment, long timeout, TimeUnit timeUnit) Deploys the specified processing unit adding it to this application
boolean	equals(Object o)
String	getName()
ProcessingUnits	getProcessingUnits()
int	hashCode()
void	setStatisticsHistorySize(int historySize)
void	undeployAndWait() Undeploys all Processing Units that are part of the application and waits until all instances have been undeployed.
boolean	undeployAndWait(long timeout, TimeUnit timeUnit) Undeploys all Processing Units that are part of the application and waits until all instances have been undeployed.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultApplication

public DefaultApplication(InternalAdmin admin,
                          String name)

Method Detail

getProcessingUnits

public ProcessingUnits getProcessingUnits()

Specified by:

getProcessingUnits in interface Application

Returns:

the processing units associated with the application

getName

public String getName()

Specified by:

getName in interface Application

Returns:

the name of the application.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

setStatisticsHistorySize

public void setStatisticsHistorySize(int historySize)

Specified by:

setStatisticsHistorySize in interface Application

Parameters:

historySize - the amount of statistics objects to keep.

undeployAndWait

public void undeployAndWait()

Description copied from interface: Application

Undeploys all Processing Units that are part of the application and waits until all instances have been undeployed. In case of an Elastic processing unit, also waits for containers to shutdown. The processing units are undeployed in the reverse dependency order (if feeder depends on space, then space is undeployed and only then space is undeployed)

The undeployment process will wait indefinitely and return when all processing units have undeployed.

Specified by:

undeployAndWait in interface Application

undeployAndWait

public boolean undeployAndWait(long timeout,
                               TimeUnit timeUnit)

Description copied from interface: Application

Undeploys all Processing Units that are part of the application and waits until all instances have been undeployed. In case of an Elastic processing unit, also waits for containers to shutdown. The processing units are undeployed in the reverse dependency order (if feeder depends on space, then space is undeployed and only then space is undeployed)

The undeployment process waits for the specified timeout and return when all processing units of the application has been undeployed or timeout expired. * @return true if all processing units have undeployed, false if undeployment process is incomplete and the timeout expired.

Specified by:

undeployAndWait in interface Application

deployProcessingUnit

public ProcessingUnit deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment,
                                           long timeout,
                                           TimeUnit timeUnit)

Description copied from interface: Application

Deploys the specified processing unit adding it to this application

Specified by:

deployProcessingUnit in interface Application

deployProcessingUnit

public ProcessingUnit deployProcessingUnit(ProcessingUnitDeploymentTopology puDeployment)

Description copied from interface: Application

Deploys the specified processing unit adding it to this application

Specified by:

deployProcessingUnit in interface Application