Package org.openspaces.admin.internal.transport

Class DefaultTransport

java.lang.Object

org.openspaces.admin.internal.transport.DefaultTransport

All Implemented Interfaces:

InternalTransport, StatisticsMonitor, Transport, TransportLRMIMonitoring, VirtualMachineAware

public class DefaultTransport
extends Object
implements InternalTransport, TransportLRMIMonitoring

Author:

kimchy

Field Summary

Fields inherited from interface org.openspaces.admin.StatisticsMonitor

DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL

Constructor Summary

Constructors

Constructor	Description
DefaultTransport(NIODetails nioDetails, InternalTransports transports)

Method Summary

Modifier and Type	Method	Description
void	addTransportInfoProvider(InternalTransportInfoProvider transportInfoProvider)
void	disableMonitoring()	Disabled lrmi monitoring (gigaspaces internal remoting layer).
void	enableMonitoring()	Enables lrmi monitoring (gigaspaces internal remoting layer), this will cause the target transport to start tracking lrmi activity which can later be viewed by calling.
boolean	equals(Object o)
LRMIMonitoringDetails	fetchMonitoringDetails()	Return lrmi (gigaspaces internal remoting layer) monitoring details.
String	getBindHost()	Returns the host name or address the communication layer bounded on.
TransportDetails	getDetails()	Returns the details (non changeable) of the transport.
String	getHostAddress()	Returns the host address of the transport.
String	getHostName()	Returns the host address of the transport.
TransportLRMIMonitoring	getLRMIMonitoring()	Return the LRMI monitoring of this transport.
int	getPort()	Returns the port number the communication layer is using.
TransportStatistics	getStatistics()	Returns the transport statistics.
TransportStatisticsChangedEventManager	getStatisticsChanged()	Allows to register for TransportStatisticsChangedEvents.
String	getUid()	Returns the UID of the transport.
VirtualMachine	getVirtualMachine()	Returns the virtual machine the grid component is running within.
int	hashCode()
boolean	hasTransportInfoProviders()
boolean	isMonitoring()	Returns true if statistics are now being monitored.
void	removeTransportInfoProvider(InternalTransportInfoProvider transportInfoProvider)
void	setStatisticsHistorySize(int historySize)	Sets the history size of number of statistics stored.
void	setStatisticsInterval(long interval, TimeUnit timeUnit)	Sets the statistics interval, automatically updating the monitoring scheduled tasks if monitoring is enabled.
void	setVirtualMachine(VirtualMachine virtualMachine)
void	startStatisticsMonitor()	Starts the statistics monitor, starting a scheduled monitor that polls for statistics.
void	stopStatisticsMonitor()	Stops the statistics monitor.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultTransport

public DefaultTransport(NIODetails nioDetails,
 InternalTransports transports)

Method Details

getStatisticsChanged

public TransportStatisticsChangedEventManager getStatisticsChanged()

Description copied from interface: Transport

Allows to register for TransportStatisticsChangedEvents.

Note, the transport needs to be in a monitoring state. See StatisticsMonitor.startStatisticsMonitor().

Specified by:

getStatisticsChanged in interface Transport

addTransportInfoProvider

public void addTransportInfoProvider(InternalTransportInfoProvider transportInfoProvider)

Specified by:

addTransportInfoProvider in interface InternalTransport

removeTransportInfoProvider

public void removeTransportInfoProvider(InternalTransportInfoProvider transportInfoProvider)

Specified by:

removeTransportInfoProvider in interface InternalTransport

hasTransportInfoProviders

public boolean hasTransportInfoProviders()

Specified by:

hasTransportInfoProviders in interface InternalTransport

getUid

public String getUid()

Description copied from interface: Transport

Returns the UID of the transport.

Specified by:

getUid in interface Transport

getHostAddress

public String getHostAddress()

Description copied from interface: Transport

Returns the host address of the transport.

Specified by:

getHostAddress in interface Transport

See Also:

• InetAddress.getHostAddress()

getHostName

public String getHostName()

Description copied from interface: Transport

Returns the host address of the transport.

Specified by:

getHostName in interface Transport

See Also:

• InetAddress.getHostName()

getBindHost

public String getBindHost()

Description copied from interface: Transport

Returns the host name or address the communication layer bounded on.

Specified by:

getBindHost in interface Transport

getPort

public int getPort()

Description copied from interface: Transport

Returns the port number the communication layer is using.

Specified by:

getPort in interface Transport

getDetails

public TransportDetails getDetails()

Description copied from interface: Transport

Returns the details (non changeable) of the transport.

Specified by:

getDetails in interface Transport

setVirtualMachine

public void setVirtualMachine(VirtualMachine virtualMachine)

Specified by:

setVirtualMachine in interface InternalTransport

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

getStatistics

public TransportStatistics getStatistics()

Description copied from interface: Transport

Returns the transport statistics.

Specified by:

getStatistics in interface Transport

setStatisticsInterval

public void setStatisticsInterval(long interval,
 TimeUnit timeUnit)

Description copied from interface: StatisticsMonitor

Sets the statistics interval, automatically updating the monitoring scheduled tasks if monitoring is enabled.

Specified by:

setStatisticsInterval in interface StatisticsMonitor

setStatisticsHistorySize

public void setStatisticsHistorySize(int historySize)

Description copied from interface: StatisticsMonitor

Sets the history size of number of statistics stored.

Specified by:

setStatisticsHistorySize in interface StatisticsMonitor

startStatisticsMonitor

public void startStatisticsMonitor()

Description copied from interface: StatisticsMonitor

Starts the statistics monitor, starting a scheduled monitor that polls for statistics. Monitoring is required only when wanting to receive statistics change events.

Specified by:

startStatisticsMonitor in interface StatisticsMonitor

stopStatisticsMonitor

public void stopStatisticsMonitor()

Description copied from interface: StatisticsMonitor

Stops the statistics monitor.

Specified by:

stopStatisticsMonitor in interface StatisticsMonitor

isMonitoring

public boolean isMonitoring()

Description copied from interface: StatisticsMonitor

Returns true if statistics are now being monitored.

Specified by:

isMonitoring in interface StatisticsMonitor

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getLRMIMonitoring

public TransportLRMIMonitoring getLRMIMonitoring()

Description copied from interface: Transport

Return the LRMI monitoring of this transport. See TransportLRMIMonitoring.

Specified by:

getLRMIMonitoring in interface Transport

enableMonitoring

public void enableMonitoring()

Description copied from interface: TransportLRMIMonitoring

Enables lrmi monitoring (gigaspaces internal remoting layer), this will cause the target transport to start tracking lrmi activity which can later be viewed by calling. TransportLRMIMonitoring.fetchMonitoringDetails()

Specified by:

enableMonitoring in interface TransportLRMIMonitoring

disableMonitoring

public void disableMonitoring()

Description copied from interface: TransportLRMIMonitoring

Disabled lrmi monitoring (gigaspaces internal remoting layer). TransportLRMIMonitoring.enableMonitoring()

Specified by:

disableMonitoring in interface TransportLRMIMonitoring

fetchMonitoringDetails

public LRMIMonitoringDetails fetchMonitoringDetails()

Description copied from interface: TransportLRMIMonitoring

Return lrmi (gigaspaces internal remoting layer) monitoring details. This will only work if lrmi monitoring was previously enabled, either by admin API, Jmx or system property. This will include monitoring details of inbound invocation on hosted service and outbound invocation via proxies that exists within the targeted transport (Jvm). TransportLRMIMonitoring.enableMonitoring()

Specified by:

fetchMonitoringDetails in interface TransportLRMIMonitoring