Package org.openspaces.admin.internal.transport

Class DefaultTransports

java.lang.Object

org.openspaces.admin.internal.transport.DefaultTransports

All Implemented Interfaces:

Iterable<Transport>, AdminAware, InternalTransports, StatisticsMonitor, Transports

public class DefaultTransports
extends Object
implements InternalTransports

Author:

kimchy

Field Summary

Fields inherited from interface org.openspaces.admin.StatisticsMonitor

DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL

Constructor Summary

Constructors

Constructor	Description
DefaultTransports(InternalAdmin admin)

Method Summary

Modifier and Type	Method	Description
void	addTransport(Transport transport)
Admin	getAdmin()	Returns the Admin associated with this element.
TransportsDetails	getDetails()	Returns the aggregated details (non changeable) of all the currently discovered transports.
int	getSize()	Returns the number of currently discovered transports.
TransportsStatistics	getStatistics()	Returns the aggregated statistics of all the currently discovered transports.
TransportsStatisticsChangedEventManager	getStatisticsChanged()	Allows to register for aggregated TransportsStatisticsChangedEvents.
Transport	getTransportByHostAndPort(String host, int port)	Returns the transport that is bounded on the specified host and port.
Transport	getTransportByUID(String uid)	Returns the transport based on the specified UID.
Transport[]	getTransports()	Returns all the currently discovered transports.
Transport[]	getTransports(String host)	Returns all the transports bounded on the specified host.
TransportStatisticsChangedEventManager	getTransportStatisticsChanged()	Allows to register for transport level TransportStatisticsChangedEvents.
boolean	isMonitoring()	Returns true if statistics are now being monitored.
Iterator<Transport>	iterator()
void	removeTransport(String uid)
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	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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

DefaultTransports

public DefaultTransports(InternalAdmin admin)

Method Details

getAdmin

public Admin getAdmin()

Description copied from interface: AdminAware

Returns the Admin associated with this element.

Specified by:

getAdmin in interface AdminAware

getTransportStatisticsChanged

public TransportStatisticsChangedEventManager getTransportStatisticsChanged()

Description copied from interface: Transports

Allows to register for transport level TransportStatisticsChangedEvents.

Note, the transports must be in a monitoring state in order to receive the events.

Specified by:

getTransportStatisticsChanged in interface Transports

getStatisticsChanged

public TransportsStatisticsChangedEventManager getStatisticsChanged()

Description copied from interface: Transports

Allows to register for aggregated TransportsStatisticsChangedEvents.

Note, the transports must be in a monitoring state in order to receive the events.

Specified by:

getStatisticsChanged in interface Transports

getTransports

public Transport[] getTransports()

Description copied from interface: Transports

Returns all the currently discovered transports.

Specified by:

getTransports in interface Transports

iterator

public Iterator<Transport> iterator()

Specified by:

iterator in interface Iterable<Transport>

getTransports

public Transport[] getTransports(String host)

Description copied from interface: Transports

Returns all the transports bounded on the specified host.

Specified by:

getTransports in interface Transports

See Also:

• Transport.getBindHost()

getTransportByHostAndPort

public Transport getTransportByHostAndPort(String host,
 int port)

Description copied from interface: Transports

Returns the transport that is bounded on the specified host and port.

Specified by:

getTransportByHostAndPort in interface Transports

See Also:

• Transport.getBindHost()
• Transport.getPort()

getTransportByUID

public Transport getTransportByUID(String uid)

Description copied from interface: Transports

Returns the transport based on the specified UID.

Specified by:

getTransportByUID in interface Transports

getSize

public int getSize()

Description copied from interface: Transports

Returns the number of currently discovered transports.

Specified by:

getSize in interface Transports

getDetails

public TransportsDetails getDetails()

Description copied from interface: Transports

Returns the aggregated details (non changeable) of all the currently discovered transports.

Specified by:

getDetails in interface Transports

getStatistics

public TransportsStatistics getStatistics()

Description copied from interface: Transports

Returns the aggregated statistics of all the currently discovered transports.

Specified by:

getStatistics in interface Transports

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

addTransport

public void addTransport(Transport transport)

Specified by:

addTransport in interface InternalTransports

removeTransport

public void removeTransport(String uid)

Specified by:

removeTransport in interface InternalTransports