Package org.openspaces.admin.internal.gateway

Class DefaultGatewayProcessingUnit

java.lang.Object

org.openspaces.admin.internal.gateway.DefaultGatewayProcessingUnit

All Implemented Interfaces:

AdminAware, DiscoverableComponent, GatewayProcessingUnit, GridComponent, MachineAware, OperatingSystemAware, TransportAware, VirtualMachineAware, ZoneAware

public class DefaultGatewayProcessingUnit
extends Object
implements GatewayProcessingUnit

Since:

8.0.4

Author:

eitany

Constructor Summary

Constructors

Constructor	Description
DefaultGatewayProcessingUnit(InternalAdmin admin, Gateway gateway, ProcessingUnitInstance processingUnitInstance, GatewayServiceDetails gatewayServiceDetails)

Method Summary

Modifier and Type	Method	Description
Admin	getAdmin()	Returns the Admin associated with this element.
int	getCommunicationPort()	Returns the communication port this gateway processing unit is using.
GatewayDelegator	getDelegator()	Returns the delegator of this gateway or null if no delegator exists in this gateway.
int	getDiscoveryPort()	Returns the discovery port this gateway processing unit is using to publish it self.
Gateway	getGateway()	Returns the Gateway this gateway processing unit belongs to.
Machine	getMachine()	Returns the machine the component is running on.
OperatingSystem	getOperatingSystem()	Returns the operating system the grid component is running within.
ProcessingUnit	getProcessingUnit()	Returns the hosting ProcessingUnit.
ProcessingUnitInstance	getProcessingUnitInstance()
GatewaySink	getSink()	Returns the sink of this gateway or null if no sink exists in this gateway.
Transport	getTransport()	Returns the transport the grid component is using.
String	getUid()	Returns the unique id of the grid component.
VirtualMachine	getVirtualMachine()	Returns the virtual machine the grid component is running within.
Map<String,Zone>	getZones()	Use GridServiceContainer.getExactZones() or GridServiceAgent.getExactZones()
boolean	isDiscovered()	Returns true if the component is currently discovered from the lookup service.
boolean	isStartEmbeddedLus()	Returns whether this gateway processing unit is starting an embedded lookup service for cross gateway discovery purpose.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultGatewayProcessingUnit

public DefaultGatewayProcessingUnit(InternalAdmin admin,
 Gateway gateway,
 ProcessingUnitInstance processingUnitInstance,
 GatewayServiceDetails gatewayServiceDetails)

Method Details

getProcessingUnitInstance

public ProcessingUnitInstance getProcessingUnitInstance()

getUid

public String getUid()

Description copied from interface: GridComponent

Returns the unique id of the grid component.

Specified by:

getUid in interface GridComponent

isDiscovered

public boolean isDiscovered()

Description copied from interface: DiscoverableComponent

Returns true if the component is currently discovered from the lookup service. false if an event of component removal was sent from the lookup service.

Specified by:

isDiscovered in interface DiscoverableComponent

getAdmin

public Admin getAdmin()

Description copied from interface: AdminAware

Returns the Admin associated with this element.

Specified by:

getAdmin in interface AdminAware

getMachine

public Machine getMachine()

Description copied from interface: MachineAware

Returns the machine the component is running on.

Specified by:

getMachine in interface MachineAware

getTransport

public Transport getTransport()

Description copied from interface: TransportAware

Returns the transport the grid component is using.

Specified by:

getTransport in interface TransportAware

getOperatingSystem

public OperatingSystem getOperatingSystem()

Description copied from interface: OperatingSystemAware

Returns the operating system the grid component is running within.

Specified by:

getOperatingSystem in interface OperatingSystemAware

getVirtualMachine

public VirtualMachine getVirtualMachine()

Description copied from interface: VirtualMachineAware

Returns the virtual machine the grid component is running within.

Specified by:

getVirtualMachine in interface VirtualMachineAware

getZones

public Map<String,Zone> getZones()

Description copied from interface: ZoneAware

Use GridServiceContainer.getExactZones() or GridServiceAgent.getExactZones()

Specified by:

getZones in interface ZoneAware

getGateway

public Gateway getGateway()

Description copied from interface: GatewayProcessingUnit

Returns the Gateway this gateway processing unit belongs to.

Specified by:

getGateway in interface GatewayProcessingUnit

getProcessingUnit

public ProcessingUnit getProcessingUnit()

Description copied from interface: GatewayProcessingUnit

Returns the hosting ProcessingUnit.

Specified by:

getProcessingUnit in interface GatewayProcessingUnit

getSink

public GatewaySink getSink()

Description copied from interface: GatewayProcessingUnit

Returns the sink of this gateway or null if no sink exists in this gateway.

Specified by:

getSink in interface GatewayProcessingUnit

getDelegator

public GatewayDelegator getDelegator()

Description copied from interface: GatewayProcessingUnit

Returns the delegator of this gateway or null if no delegator exists in this gateway.

Specified by:

getDelegator in interface GatewayProcessingUnit

getCommunicationPort

public int getCommunicationPort()

Description copied from interface: GatewayProcessingUnit

Returns the communication port this gateway processing unit is using.

Specified by:

getCommunicationPort in interface GatewayProcessingUnit

getDiscoveryPort

public int getDiscoveryPort()

Description copied from interface: GatewayProcessingUnit

Returns the discovery port this gateway processing unit is using to publish it self.

Specified by:

getDiscoveryPort in interface GatewayProcessingUnit

isStartEmbeddedLus

public boolean isStartEmbeddedLus()

Description copied from interface: GatewayProcessingUnit

Returns whether this gateway processing unit is starting an embedded lookup service for cross gateway discovery purpose.

Specified by:

isStartEmbeddedLus in interface GatewayProcessingUnit