public class DefaultAggregateEndpointManager extends Object implements AggregateEndpointManager
Constructor and Description |
---|
DefaultAggregateEndpointManager(ConcurrentMap<EndpointQualifier,EndpointManager<TcpIpConnection>> endpointManagers) |
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 . |
public DefaultAggregateEndpointManager(ConcurrentMap<EndpointQualifier,EndpointManager<TcpIpConnection>> endpointManagers)
public Set<TcpIpConnection> getActiveConnections()
AggregateEndpointManager
getActiveConnections
in interface AggregateEndpointManager
public Set<TcpIpConnection> getConnections()
AggregateEndpointManager
getConnections
in interface AggregateEndpointManager
public EndpointManager<TcpIpConnection> getEndpointManager(EndpointQualifier qualifier)
public void addConnectionListener(ConnectionListener listener)
ConnectionListenable
If the same listener is registered multiple times, it will be notified multiple times.
addConnectionListener
in interface ConnectionListenable
listener
- the ConnectionListener to add.public Map<EndpointQualifier,NetworkStats> getNetworkStats()
AggregateEndpointManager
EndpointQualifier
.
Stats are available only when Advanced Networking is enabled.getNetworkStats
in interface AggregateEndpointManager
Copyright © 2019 Hazelcast, Inc.. All rights reserved.