org.openspaces.admin.internal.gateway

Class DefaultGatewayProcessingUnits

java.lang.Object

org.openspaces.admin.internal.gateway.DefaultGatewayProcessingUnits

All Implemented Interfaces:

Iterable<GatewayProcessingUnit>, AdminAware, GatewayProcessingUnits, InternalGatewayProcessingUnits

public class DefaultGatewayProcessingUnits
extends Object
implements InternalGatewayProcessingUnits

Since:

9.5

Author:

evgeny

Constructor Summary

Constructors

Constructor and Description
DefaultGatewayProcessingUnits(DefaultAdmin admin)

Method Summary

Modifier and Type	Method and Description
void	addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)
void	addLifecycleListener(GatewayProcessingUnitLifecycleEventListener eventListener) Allows to add a GatewayProcessingUnitLifecycleEventListener.
Admin	getAdmin() Returns the Admin associated with this element.
GatewayProcessingUnit	getGatewayProcessingUnit(String uid) Returns the GatewayProcessingUnit for the given gateway processing unit name.
GatewayProcessingUnitAddedEventManager	getGatewayProcessingUnitAdded() Returns an event manager allowing to register GatewayProcessingUnitAddedEventListeners.
GatewayProcessingUnitRemovedEventManager	getGatewayProcessingUnitRemoved() Returns an event manager allowing to register GatewayProcessingUnitRemovedEventListeners.
GatewayProcessingUnit[]	getGatewayProcessingUnits() Returns the GatewayProcessingUnits currently deployed.
Map<String,GatewayProcessingUnit>	getNames() Returns a map of GatewayProcessingUnit keyed by their respective names.
int	getSize() Returns the number of currently deployed GatewayProcessingUnits.
boolean	isEmpty() Returns true if there are no currently deployed processing units.
Iterator<GatewayProcessingUnit>	iterator()
GatewayProcessingUnit	removeGatewayProcessingUnit(String uid)
void	removeLifecycleListener(GatewayProcessingUnitLifecycleEventListener eventListener) Allows to remove a GatewayProcessingUnitLifecycleEventListener.
GatewayProcessingUnit	waitFor(String gatewayProcessingUnitName) Waits indefinitely till the gateway processing unit is identified as deployed.
GatewayProcessingUnit	waitFor(String gatewaysProcessingUnitName, long timeout, TimeUnit timeUnit) Waits for the specified timeout (in time interval) till the processing unit is identified as deployed.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DefaultGatewayProcessingUnits

public DefaultGatewayProcessingUnits(DefaultAdmin admin)

Method Detail

addGatewayProcessingUnit

public void addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)

Specified by:

addGatewayProcessingUnit in interface InternalGatewayProcessingUnits

removeGatewayProcessingUnit

public GatewayProcessingUnit removeGatewayProcessingUnit(String uid)

Specified by:

removeGatewayProcessingUnit in interface InternalGatewayProcessingUnits

getAdmin

public Admin getAdmin()

Description copied from interface: AdminAware

Returns the Admin associated with this element.

Specified by:

getAdmin in interface AdminAware

getSize

public int getSize()

Description copied from interface: GatewayProcessingUnits

Returns the number of currently deployed GatewayProcessingUnits.

Specified by:

getSize in interface GatewayProcessingUnits

isEmpty

public boolean isEmpty()

Description copied from interface: GatewayProcessingUnits

Returns true if there are no currently deployed processing units.

Specified by:

isEmpty in interface GatewayProcessingUnits

getGatewayProcessingUnits

public GatewayProcessingUnit[] getGatewayProcessingUnits()

Description copied from interface: GatewayProcessingUnits

Returns the GatewayProcessingUnits currently deployed.

Specified by:

getGatewayProcessingUnits in interface GatewayProcessingUnits

getGatewayProcessingUnit

public GatewayProcessingUnit getGatewayProcessingUnit(String uid)

Description copied from interface: GatewayProcessingUnits

Returns the GatewayProcessingUnit for the given gateway processing unit name.

Specified by:

getGatewayProcessingUnit in interface GatewayProcessingUnits

getGatewayProcessingUnitAdded

public GatewayProcessingUnitAddedEventManager getGatewayProcessingUnitAdded()

Description copied from interface: GatewayProcessingUnits

Returns an event manager allowing to register GatewayProcessingUnitAddedEventListeners.

Specified by:

getGatewayProcessingUnitAdded in interface GatewayProcessingUnits

getGatewayProcessingUnitRemoved

public GatewayProcessingUnitRemovedEventManager getGatewayProcessingUnitRemoved()

Description copied from interface: GatewayProcessingUnits

Returns an event manager allowing to register GatewayProcessingUnitRemovedEventListeners.

Specified by:

getGatewayProcessingUnitRemoved in interface GatewayProcessingUnits

addLifecycleListener

public void addLifecycleListener(GatewayProcessingUnitLifecycleEventListener eventListener)

Description copied from interface: GatewayProcessingUnits

Allows to add a GatewayProcessingUnitLifecycleEventListener.

Specified by:

addLifecycleListener in interface GatewayProcessingUnits

removeLifecycleListener

public void removeLifecycleListener(GatewayProcessingUnitLifecycleEventListener eventListener)

Description copied from interface: GatewayProcessingUnits

Allows to remove a GatewayProcessingUnitLifecycleEventListener.

Specified by:

removeLifecycleListener in interface GatewayProcessingUnits

iterator

public Iterator<GatewayProcessingUnit> iterator()

Specified by:

iterator in interface Iterable<GatewayProcessingUnit>

getNames

public Map<String,GatewayProcessingUnit> getNames()

Description copied from interface: GatewayProcessingUnits

Returns a map of GatewayProcessingUnit keyed by their respective names.

Specified by:

getNames in interface GatewayProcessingUnits

waitFor

public GatewayProcessingUnit waitFor(String gatewayProcessingUnitName)

Description copied from interface: GatewayProcessingUnits

Waits indefinitely till the gateway processing unit is identified as deployed. Returns the GatewayProcessingUnit.

Specified by:

waitFor in interface GatewayProcessingUnits

waitFor

public GatewayProcessingUnit waitFor(String gatewaysProcessingUnitName,
                                     long timeout,
                                     TimeUnit timeUnit)

Description copied from interface: GatewayProcessingUnits

Waits for the specified timeout (in time interval) till the processing unit is identified as deployed. Returns the GatewayProcessingUnit. Return null if the gateway processing unit is not deployed within the specified timeout.

Specified by:

waitFor in interface GatewayProcessingUnits