com.hazelcast.internal.nio

Class DefaultAggregateEndpointManager

java.lang.Object

com.hazelcast.internal.nio.DefaultAggregateEndpointManager

All Implemented Interfaces:

AggregateEndpointManager, ConnectionListenable

public class DefaultAggregateEndpointManager
extends Object
implements AggregateEndpointManager

Constructor Summary

Constructors

Constructor and Description
DefaultAggregateEndpointManager(ConcurrentMap<EndpointQualifier,EndpointManager<TcpIpConnection>> endpointManagers)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener listener) Registers a ConnectionListener.
Set<TcpIpConnection>	getActiveConnections() Returns all active connections from the underlying EndpointManagers.
Set<TcpIpConnection>	getConnections() Returns all connections that have been successfully established by the underlying EndpointManagers.
EndpointManager<TcpIpConnection>	getEndpointManager(EndpointQualifier qualifier)
Map<EndpointQualifier,NetworkStats>	getNetworkStats() Returns network stats for inbound and outbound traffic per EndpointQualifier.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultAggregateEndpointManager

public DefaultAggregateEndpointManager(ConcurrentMap<EndpointQualifier,EndpointManager<TcpIpConnection>> endpointManagers)

Method Detail

getActiveConnections

public Set<TcpIpConnection> getActiveConnections()

Description copied from interface: AggregateEndpointManager

Returns all active connections from the underlying EndpointManagers.

Specified by:

getActiveConnections in interface AggregateEndpointManager

Returns:

active connections

getConnections

public Set<TcpIpConnection> getConnections()

Description copied from interface: AggregateEndpointManager

Returns all connections that have been successfully established by the underlying EndpointManagers.

Specified by:

getConnections in interface AggregateEndpointManager

Returns:

active connections

getEndpointManager

public EndpointManager<TcpIpConnection> getEndpointManager(EndpointQualifier qualifier)

addConnectionListener

public void addConnectionListener(ConnectionListener listener)

Description copied from interface: ConnectionListenable

Registers a ConnectionListener.

If the same listener is registered multiple times, it will be notified multiple times.

Specified by:

addConnectionListener in interface ConnectionListenable

Parameters:

listener - the ConnectionListener to add.

getNetworkStats

public Map<EndpointQualifier,NetworkStats> getNetworkStats()

Description copied from interface: AggregateEndpointManager

Returns network stats for inbound and outbound traffic per EndpointQualifier. Stats are available only when Advanced Networking is enabled.

Specified by:

getNetworkStats in interface AggregateEndpointManager

Returns:

network stats per endpoint