Package dev.getelements.elements.rt.remote

Class JndiSrvInstanceDiscoveryService

java.lang.Object

dev.getelements.elements.rt.remote.JndiSrvInstanceDiscoveryService

All Implemented Interfaces:

InstanceDiscoveryService

public class JndiSrvInstanceDiscoveryService
extends Object
implements InstanceDiscoveryService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SRV_AUTHORITATIVE

Constructor Summary

Constructors

Constructor	Description
JndiSrvInstanceDiscoveryService()

Method Summary

Modifier and Type	Method	Description
Collection<InstanceHostInfo>	getKnownHosts()	Gets the known remote hosts.
String	getSrvQuery()
String	getSrvServers()
boolean	isAuthoritative()
void	setAuthoritative(boolean authoritative)
void	setSrvQuery(String srvQuery)
void	setSrvServers(String srvServers)
void	start()
void	stop()
Subscription	subscribeToDiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)	Subscribes to an event that fires when a new host joins the network.
Subscription	subscribeToUndiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)	Subscribes to an event that fires when a host leaves the network.

Methods inherited from class java.lang.Object

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

Field Details

SRV_AUTHORITATIVE

public static final String SRV_AUTHORITATIVE

See Also:

• Constant Field Values

Constructor Details

JndiSrvInstanceDiscoveryService

public JndiSrvInstanceDiscoveryService()

Method Details

start

public void start()

Specified by:

start in interface InstanceDiscoveryService

stop

public void stop()

Specified by:

stop in interface InstanceDiscoveryService

subscribeToDiscovery

public Subscription subscribeToDiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)

Description copied from interface: InstanceDiscoveryService

Subscribes to an event that fires when a new host joins the network.

Specified by:

subscribeToDiscovery in interface InstanceDiscoveryService

Parameters:

instanceHostInfoConsumer - the InstanceHostInfo

Returns:

the Subscription

subscribeToUndiscovery

public Subscription subscribeToUndiscovery(Consumer<InstanceHostInfo> instanceHostInfoConsumer)

Description copied from interface: InstanceDiscoveryService

Subscribes to an event that fires when a host leaves the network.

Specified by:

subscribeToUndiscovery in interface InstanceDiscoveryService

Parameters:

instanceHostInfoConsumer - the InstanceHostInfo

Returns:

the Subscription

getKnownHosts

public Collection<InstanceHostInfo> getKnownHosts()

Description copied from interface: InstanceDiscoveryService

Gets the known remote hosts.

Specified by:

getKnownHosts in interface InstanceDiscoveryService

Returns:

a Set<String> containing the remote hosts

getSrvQuery

public String getSrvQuery()

setSrvQuery

@Inject
public void setSrvQuery(@Named("dev.getelements.elements.rt.srv.query")
 String srvQuery)

getSrvServers

public String getSrvServers()

setSrvServers

@Inject
public void setSrvServers(@Named("dev.getelements.elements.rt.srv.servers")
 String srvServers)

isAuthoritative

public boolean isAuthoritative()

setAuthoritative

@Inject
public void setAuthoritative(@Named("dev.getelements.elements.rt.srv.authoritative")
 boolean authoritative)