services.moleculer.transporter.tcp

Class UDPLocator

java.lang.Object

services.moleculer.transporter.tcp.UDPLocator

public class UDPLocator
extends java.lang.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 and Description
protected static org.slf4j.Logger	logger
protected int	nextIndex
protected java.lang.String	nodeID Current NodeID
protected int	numberOfSubmittedPackets
protected java.util.ArrayList<UDPReceiver>	receivers
protected java.util.concurrent.ScheduledExecutorService	scheduler Sender's executor
protected java.util.concurrent.ScheduledFuture<?>	timer Cancelable timer of sender
protected TcpTransporter	transporter Parent transporter

Constructor Summary

Constructors

Constructor and Description
UDPLocator(java.lang.String nodeID, TcpTransporter transporter, java.util.concurrent.ScheduledExecutorService scheduler)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.slf4j.Logger logger

nodeID

protected final java.lang.String nodeID

Current NodeID

scheduler

protected final java.util.concurrent.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 java.util.ArrayList<UDPReceiver> receivers

timer

protected volatile java.util.concurrent.ScheduledFuture<?> timer

Cancelable timer of sender

Constructor Detail

UDPLocator

public UDPLocator(java.lang.String nodeID,
                  TcpTransporter transporter,
                  java.util.concurrent.ScheduledExecutorService scheduler)

Method Detail

connect

public void connect()
             throws java.lang.Exception

Throws:

java.lang.Exception

startReceivers

protected void startReceivers(java.net.NetworkInterface ni,
                              java.lang.String udpMulticast,
                              boolean udpBroadcast)
                       throws java.lang.Exception

Throws:

java.lang.Exception

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

disconnect

public void disconnect()

send

protected void send()