services.moleculer.transporter.tcp

Class UDPReceiver

java.lang.Object

services.moleculer.transporter.tcp.UDPReceiver

Direct Known Subclasses:

UDPBroadcastReceiver, UDPMulticastReceiver

public abstract class UDPReceiver
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	debug Debug mode
protected java.util.concurrent.ExecutorService	executor Receiver's executor
protected static org.slf4j.Logger	logger
protected java.lang.String	namespace Current namespace
protected java.lang.String	nodeID Current NodeID
protected int	port TCP port (used by the Transporter and Gossiper services)
protected TcpTransporter	transporter Parent transporter
protected java.lang.String	udpAddress IP address
protected int	udpMulticastTTL UDP multicast TTL
protected int	udpPort UDP broadcast/multicast port
protected boolean	udpReuseAddr Resuse addresses
protected boolean	useHostname Use hostnames instead of IP addresses As the DHCP environment is dynamic, any later attempt to use IPs instead hostnames would most likely yield false results.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	UDPReceiver(java.lang.String nodeID, java.lang.String udpAddress, TcpTransporter transporter)

Method Summary

Modifier and Type	Method and Description
protected void	connect()
protected void	disconnect()
protected void	processReceivedMessage(java.net.DatagramPacket packet, byte[] buffer)
protected abstract void	receive()
protected abstract void	send()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.slf4j.Logger logger

namespace

protected final java.lang.String namespace

Current namespace

debug

protected final boolean debug

Debug mode

useHostname

protected final boolean useHostname

Use hostnames instead of IP addresses As the DHCP environment is dynamic, any later attempt to use IPs instead hostnames would most likely yield false results. Therefore, use hostnames if you are using DHCP.

nodeID

protected final java.lang.String nodeID

Current NodeID

udpAddress

protected final java.lang.String udpAddress

IP address

udpReuseAddr

protected final boolean udpReuseAddr

Resuse addresses

udpPort

protected final int udpPort

UDP broadcast/multicast port

udpMulticastTTL

protected final int udpMulticastTTL

UDP multicast TTL

port

protected final int port

TCP port (used by the Transporter and Gossiper services)

executor

protected java.util.concurrent.ExecutorService executor

Receiver's executor

transporter

protected final TcpTransporter transporter

Parent transporter

Constructor Detail

UDPReceiver

protected UDPReceiver(java.lang.String nodeID,
                      java.lang.String udpAddress,
                      TcpTransporter transporter)

Method Detail

connect

protected void connect()
                throws java.lang.Exception

Throws:

java.lang.Exception

disconnect

protected void disconnect()

send

protected abstract void send()

receive

protected abstract void receive()

processReceivedMessage

protected void processReceivedMessage(java.net.DatagramPacket packet,
                                      byte[] buffer)