io.vertx.core.spi.cluster.impl

Class DefaultNodeSelector

java.lang.Object

io.vertx.core.spi.cluster.impl.DefaultNodeSelector

All Implemented Interfaces:

NodeSelector, VertxServiceProvider

public class DefaultNodeSelector
extends Object
implements NodeSelector

Author:

Thomas Segismont

Constructor Summary

Constructors

Constructor and Description
DefaultNodeSelector()

Method Summary

Modifier and Type	Method and Description
void	eventBusStarted() Invoked after the clustered EventBus has started.
void	init(Vertx vertx, ClusterManager clusterManager) Invoked before the vertx instance tries to join the cluster.
void	registrationsLost() Invoked by the ClusterManager when some handler registrations have been lost.
void	registrationsUpdated(RegistrationUpdateEvent event) Invoked by the ClusterManager when messaging handler registrations are added or removed.
void	selectForPublish(Message<?> message, Promise<Iterable<String>> promise) Select a node for publishing the given message.
void	selectForSend(Message<?> message, Promise<String> promise) Select a node for sending the given message.
boolean	wantsUpdatesFor(String address) Invoked by the ClusterManager to determine if the node selector wants updates for the given address.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertx.core.spi.cluster.NodeSelector

init

Constructor Detail

DefaultNodeSelector

public DefaultNodeSelector()

Method Detail

init

public void init(Vertx vertx,
                 ClusterManager clusterManager)

Description copied from interface: NodeSelector

Invoked before the vertx instance tries to join the cluster.

Specified by:

init in interface NodeSelector

eventBusStarted

public void eventBusStarted()

Description copied from interface: NodeSelector

Invoked after the clustered EventBus has started.

Specified by:

eventBusStarted in interface NodeSelector

selectForSend

public void selectForSend(Message<?> message,
                          Promise<String> promise)

Description copied from interface: NodeSelector

Select a node for sending the given message.

The provided promise needs to be completed with Promise.tryComplete(T) and Promise.tryFail(java.lang.Throwable) as it might completed outside the selector.

Specified by:

selectForSend in interface NodeSelector

selectForPublish

public void selectForPublish(Message<?> message,
                             Promise<Iterable<String>> promise)

Description copied from interface: NodeSelector

Select a node for publishing the given message.

The provided promise needs to be completed with Promise.tryComplete(T) and Promise.tryFail(java.lang.Throwable) as it might completed outside the selector.

Specified by:

selectForPublish in interface NodeSelector

registrationsUpdated

public void registrationsUpdated(RegistrationUpdateEvent event)

Description copied from interface: NodeSelector

Invoked by the ClusterManager when messaging handler registrations are added or removed.

Specified by:

registrationsUpdated in interface NodeSelector

registrationsLost

public void registrationsLost()

Description copied from interface: NodeSelector

Invoked by the ClusterManager when some handler registrations have been lost.

Specified by:

registrationsLost in interface NodeSelector

wantsUpdatesFor

public boolean wantsUpdatesFor(String address)

Description copied from interface: NodeSelector

Invoked by the ClusterManager to determine if the node selector wants updates for the given address.

Specified by:

wantsUpdatesFor in interface NodeSelector

Parameters:

address - the event bus address

Returns:

true if the node selector wants updates for the given address, false otherwise