Uses of Interface
org.openspaces.admin.gateway.GatewayProcessingUnit

Packages that use GatewayProcessingUnit

Package	Description
org.openspaces.admin.gateway
org.openspaces.admin.gateway.events
org.openspaces.admin.internal.admin	Internally Used.
org.openspaces.admin.internal.gateway

Uses of GatewayProcessingUnit in org.openspaces.admin.gateway

Methods in org.openspaces.admin.gateway that return GatewayProcessingUnit

Modifier and Type	Method and Description
GatewayProcessingUnit	GatewayDelegator.getGatewayProcessingUnit() Returns the gateway this sink is part of.
GatewayProcessingUnit	GatewaySink.getGatewayProcessingUnit() Returns the gateway this sink is part of.
GatewayProcessingUnit	GatewayProcessingUnits.getGatewayProcessingUnit(String uid) Returns the GatewayProcessingUnit for the given gateway processing unit name.
GatewayProcessingUnit	Gateway.getGatewayProcessingUnit(String processingUnitName) Returns the gateway processing unit for the given processing unit name.
GatewayProcessingUnit[]	GatewayProcessingUnits.getGatewayProcessingUnits() Returns the GatewayProcessingUnits currently deployed.
GatewayProcessingUnit[]	Gateway.getGatewayProcessingUnits() Returns all the currently deployed GatewayProcessingUnits.
GatewayProcessingUnit	GatewayProcessingUnits.waitFor(String gatewayProcessingUnitName) Waits indefinitely till the gateway processing unit is identified as deployed.
GatewayProcessingUnit	GatewayProcessingUnits.waitFor(String gatewaysProcessingUnitName, long timeout, TimeUnit timeUnit) Waits for the specified timeout (in time interval) till the processing unit is identified as deployed.
GatewayProcessingUnit	Gateway.waitForGatewayProcessingUnit(String processingUnitName) Waits for the default timeout specified by Admin.setDefaultTimeout(long, TimeUnit) till the processing unit of this gateway is identified as deployed.
GatewayProcessingUnit	Gateway.waitForGatewayProcessingUnit(String processingUnitName, long timeout, TimeUnit timeUnit) Waits for the specified timeout (in time interval) till the processing unit of this gateway is identified as deployed.

Methods in org.openspaces.admin.gateway that return types with arguments of type GatewayProcessingUnit

Modifier and Type	Method and Description
Map<String,GatewayProcessingUnit>	GatewayProcessingUnits.getNames() Returns a map of GatewayProcessingUnit keyed by their respective names.
Map<String,GatewayProcessingUnit>	Gateway.getNames() Returns a map of GatewayProcessingUnit keyed by their respective names.

Uses of GatewayProcessingUnit in org.openspaces.admin.gateway.events

Methods in org.openspaces.admin.gateway.events with parameters of type GatewayProcessingUnit

Modifier and Type	Method and Description
void	ClosureGatewayProcessingUnitAddedEventListener.gatewayProcessingUnitAdded(GatewayProcessingUnit gatewayProcessingUnit)
void	DefaultGatewayProcessingUnitAddedEventManager.gatewayProcessingUnitAdded(GatewayProcessingUnit gatewayProcessingUnit)
void	GatewayProcessingUnitAddedEventListener.gatewayProcessingUnitAdded(GatewayProcessingUnit gatewayProcessingUnit) A callback indicating that a Gateways Processing Unit was added (deployed/discovered).
void	ClosureGatewayProcessingUnitRemovedEventListener.gatewayProcessingUnitRemoved(GatewayProcessingUnit gatewayProcessingUnit)
void	DefaultGatewayProcessingUnitRemovedEventManager.gatewayProcessingUnitRemoved(GatewayProcessingUnit gatewayProcessingUnit)
void	GatewayProcessingUnitRemovedEventListener.gatewayProcessingUnitRemoved(GatewayProcessingUnit gatewayProcessingUnit) A callback indicating that a Gateway Processing Unit was removed (undeployed).

Uses of GatewayProcessingUnit in org.openspaces.admin.internal.admin

Methods in org.openspaces.admin.internal.admin with parameters of type GatewayProcessingUnit

Modifier and Type	Method and Description
void	InternalAdmin.addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)
void	DefaultAdmin.addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)

Uses of GatewayProcessingUnit in org.openspaces.admin.internal.gateway

Classes in org.openspaces.admin.internal.gateway that implement GatewayProcessingUnit

Modifier and Type	Class and Description
class	DefaultGatewayProcessingUnit

Methods in org.openspaces.admin.internal.gateway that return GatewayProcessingUnit

Modifier and Type	Method and Description
GatewayProcessingUnit	DefaultGatewayDelegator.getGatewayProcessingUnit()
GatewayProcessingUnit	DefaultGatewaySink.getGatewayProcessingUnit()
GatewayProcessingUnit	DefaultGatewayProcessingUnits.getGatewayProcessingUnit(String uid)
GatewayProcessingUnit	DefaultGateway.getGatewayProcessingUnit(String processingUnitName)
GatewayProcessingUnit[]	DefaultGatewayProcessingUnits.getGatewayProcessingUnits()
GatewayProcessingUnit[]	DefaultGateway.getGatewayProcessingUnits()
GatewayProcessingUnit	DefaultGatewayProcessingUnits.removeGatewayProcessingUnit(String uid)
GatewayProcessingUnit	InternalGatewayProcessingUnits.removeGatewayProcessingUnit(String uid)
GatewayProcessingUnit	DefaultGatewayProcessingUnits.waitFor(String gatewayProcessingUnitName)
GatewayProcessingUnit	DefaultGatewayProcessingUnits.waitFor(String gatewaysProcessingUnitName, long timeout, TimeUnit timeUnit)
GatewayProcessingUnit	DefaultGateway.waitForGatewayProcessingUnit(String processingUnitName)
GatewayProcessingUnit	DefaultGateway.waitForGatewayProcessingUnit(String processingUnitName, long timeout, TimeUnit timeUnit)

Methods in org.openspaces.admin.internal.gateway that return types with arguments of type GatewayProcessingUnit

Modifier and Type	Method and Description
Map<String,GatewayProcessingUnit>	DefaultGatewayProcessingUnits.getNames()
Map<String,GatewayProcessingUnit>	DefaultGateway.getNames()
Iterator<GatewayProcessingUnit>	DefaultGatewayProcessingUnits.iterator()
Iterator<GatewayProcessingUnit>	DefaultGateway.iterator()

Methods in org.openspaces.admin.internal.gateway with parameters of type GatewayProcessingUnit

Modifier and Type	Method and Description
void	DefaultGatewayProcessingUnits.addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)
void	InternalGatewayProcessingUnits.addGatewayProcessingUnit(GatewayProcessingUnit gatewayProcessingUnit)