com.hazelcast.nio

Class UnifiedAggregateEndpointManager

java.lang.Object

com.hazelcast.nio.UnifiedAggregateEndpointManager

All Implemented Interfaces:

AggregateEndpointManager, ConnectionListenable

public class UnifiedAggregateEndpointManager
extends Object
implements AggregateEndpointManager

Constructor Summary

Constructors

Constructor and Description
UnifiedAggregateEndpointManager(TcpIpEndpointManager unified, Map<EndpointQualifier,EndpointManager<TcpIpConnection>> views)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener listener) Registers a ConnectionListener.
Collection<TcpIpConnection>	getActiveConnections()
Collection<TcpIpConnection>	getConnections()
EndpointManager<TcpIpConnection>	getEndpointManager(EndpointQualifier qualifier)
void	reset(boolean cleanListeners)

Methods inherited from class java.lang.Object

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

Constructor Detail

UnifiedAggregateEndpointManager

public UnifiedAggregateEndpointManager(TcpIpEndpointManager unified,
                                       Map<EndpointQualifier,EndpointManager<TcpIpConnection>> views)

Method Detail

getActiveConnections

public Collection<TcpIpConnection> getActiveConnections()

Specified by:

getActiveConnections in interface AggregateEndpointManager

getConnections

public Collection<TcpIpConnection> getConnections()

Specified by:

getConnections in interface AggregateEndpointManager

getEndpointManager

public EndpointManager<TcpIpConnection> getEndpointManager(EndpointQualifier qualifier)

reset

public void reset(boolean cleanListeners)

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.