Class UDPLocator

java.lang.Object

services.moleculer.transporter.tcp.UDPLocator

public class UDPLocator
extends Object

UDP multicast / broadcast discovery service of the TCP Transporter. Use the "udpMulticast" boolean parameter, to switch to multicast from broadcast.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	logger
protected int	nextIndex
protected final String	nodeID	Current NodeID
protected int	numberOfSubmittedPackets
protected final ArrayList<UDPReceiver>	receivers
protected final ScheduledExecutorService	scheduler	Sender's executor
protected ScheduledFuture<?>	timer	Cancelable timer of sender
protected final TcpTransporter	transporter	Parent transporter

Constructor Summary

Constructors

Constructor	Description
UDPLocator(String nodeID, TcpTransporter transporter, ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method	Description
void	connect()
void	disconnect()
protected void	finalize()
protected void	send()
protected void	startReceivers(NetworkInterface ni, String udpMulticast, boolean udpBroadcast)

Methods inherited from class Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

nodeID

protected final String nodeID

Current NodeID

scheduler

protected final ScheduledExecutorService scheduler

Sender's executor

transporter

protected final TcpTransporter transporter

Parent transporter

nextIndex

protected volatile int nextIndex

numberOfSubmittedPackets

protected volatile int numberOfSubmittedPackets

receivers

protected final ArrayList<UDPReceiver> receivers

timer

protected volatile ScheduledFuture<?> timer

Cancelable timer of sender

Constructor Details

UDPLocator

public UDPLocator(String nodeID,
 TcpTransporter transporter,
 ScheduledExecutorService scheduler)

Method Details

connect

public void connect()
             throws Exception

Throws:

Exception

startReceivers

protected void startReceivers(NetworkInterface ni,
 String udpMulticast,
 boolean udpBroadcast)
                       throws Exception

Throws:

Exception

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

disconnect

public void disconnect()

send

protected void send()