services.moleculer.transporter

Class Transporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

Direct Known Subclasses:

AmqpTransporter, GoogleTransporter, JmsTransporter, KafkaTransporter, MqttTransporter, NatsTransporter, NullTransporter, RedisTransporter, TcpTransporter

public abstract class Transporter
extends MoleculerComponent

Base superclass of all Transporter implementations.

See Also:

TcpTransporter, RedisTransporter, NatsTransporter, MqttTransporter, JmsTransporter, GoogleTransporter, KafkaTransporter, AmqpTransporter

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ScheduledFuture<?>	checkTimeoutTimer Cancelable "Check Activities / Infos" timer
protected boolean	debug
java.lang.String	disconnectChannel
java.lang.String	discoverBroadcastChannel
java.lang.String	discoverChannel
protected Eventbus	eventbus
java.lang.String	eventChannel
protected java.util.concurrent.ExecutorService	executor
java.lang.String	heartbeatChannel
protected int	heartbeatInterval Heartbeat sending period in SECONDS.
protected int	heartbeatTimeout Heartbeat timeout in SECONDS.
protected java.util.concurrent.ScheduledFuture<?>	heartBeatTimer Cancelable "Heart Beat" timer
java.lang.String	infoBroadcastChannel
java.lang.String	infoChannel
protected java.util.concurrent.atomic.AtomicBoolean	infoScheduled
protected Monitor	monitor
protected java.lang.String	namespace
protected java.lang.String	nodeID
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,NodeDescriptor>	nodes
protected int	offlineTimeout How long keep information in registry about the offline nodes (SECONDS).
static java.lang.String	PACKET_DISCONNECT
static java.lang.String	PACKET_DISCOVER
static java.lang.String	PACKET_EVENT
static java.lang.String	PACKET_HEARTBEAT
static java.lang.String	PACKET_INFO
static java.lang.String	PACKET_PING
static java.lang.String	PACKET_PONG
static java.lang.String	PACKET_REQUEST
static java.lang.String	PACKET_RESPONSE
java.lang.String	pingChannel
java.lang.String	pongChannel
protected boolean	preferHostname 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.
protected java.lang.String	prefix
protected ServiceRegistry	registry
java.lang.String	requestChannel
java.lang.String	responseChannel
protected java.util.concurrent.ScheduledExecutorService	scheduler
protected Serializer	serializer
protected int	subscriptionTimeout Timeout of channel subscriptions (SECONDS).
protected UidGenerator	uid

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
Transporter()
Transporter(Serializer serializer)

Method Summary

Modifier and Type	Method and Description
void	broadcastInfoPacket()
protected void	broadcastNodeConnected(io.datatree.Tree info, boolean reconnected)
protected void	broadcastNodeDisconnected(io.datatree.Tree info, boolean unexpected)
protected void	broadcastNodeUpdated(io.datatree.Tree info)
protected java.lang.String	channel(java.lang.String cmd, java.lang.String nodeID)
protected void	checkTimeouts()
abstract void	connect()
protected void	connected()
protected void	connected(boolean waitFor)
io.datatree.Tree	createPingPacket(java.lang.String id)
io.datatree.Tree	createRequestPacket(Context ctx)
protected void	error(java.lang.Throwable error) Any I/O error occured.
RemoteAddress	getAddress(java.lang.String nodeID)
java.util.Set<java.lang.String>	getAllNodeIDs()
int	getCpuUsage(java.lang.String nodeID)
io.datatree.Tree	getDescriptor(java.lang.String nodeID)
int	getHeartbeatInterval()
int	getHeartbeatTimeout()
long	getLastHeartbeatTime(java.lang.String nodeID)
java.lang.String	getNamespace()
int	getOfflineTimeout()
java.lang.String	getPrefix()
Serializer	getSerializer()
int	getSubscriptionTimeout()
boolean	isDebug()
boolean	isOnline(java.lang.String nodeID)
boolean	isPreferHostname()
protected void	processReceivedMessage(java.lang.String channel, byte[] message) Process incoming message directly (without new Task).
void	publish(java.lang.String cmd, java.lang.String nodeID, io.datatree.Tree message)
abstract void	publish(java.lang.String channel, io.datatree.Tree message)
protected void	received(java.lang.String channel, byte[] message) Process incoming message later (in a new Runnable or JoinForkTask).
protected void	sendDisconnectPacket()
protected void	sendDiscoverPacket(java.lang.String channel)
protected void	sendHeartbeatPacket()
protected void	sendInfoPacket(java.lang.String channel)
protected void	sendPongPacket(java.lang.String channel, io.datatree.Tree data)
void	setDebug(boolean debug)
void	setHeartbeatInterval(int heartbeatInterval)
void	setHeartbeatTimeout(int heartbeatTimeout)
void	setNamespace(java.lang.String namespace)
void	setOfflineTimeout(int offlineTimeout)
void	setPreferHostname(boolean preferHostname)
void	setPrefix(java.lang.String prefix)
void	setSerializer(Serializer serializer)
void	setSubscriptionTimeout(int subscriptionTimeout)
void	started(ServiceBroker broker) Initializes transporter instance.
void	stopped() Closes transporter.
abstract io.datatree.Promise	subscribe(java.lang.String channel)
io.datatree.Promise	subscribe(java.lang.String cmd, java.lang.String nodeID)
protected void	updateNodeInfo(java.lang.String sender, io.datatree.Tree info)

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

PACKET_EVENT

public static final java.lang.String PACKET_EVENT

See Also:

Constant Field Values

PACKET_REQUEST

public static final java.lang.String PACKET_REQUEST

See Also:

Constant Field Values

PACKET_RESPONSE

public static final java.lang.String PACKET_RESPONSE

See Also:

Constant Field Values

PACKET_DISCOVER

public static final java.lang.String PACKET_DISCOVER

See Also:

Constant Field Values

PACKET_INFO

public static final java.lang.String PACKET_INFO

See Also:

Constant Field Values

PACKET_DISCONNECT

public static final java.lang.String PACKET_DISCONNECT

See Also:

Constant Field Values

PACKET_HEARTBEAT

public static final java.lang.String PACKET_HEARTBEAT

See Also:

Constant Field Values

PACKET_PING

public static final java.lang.String PACKET_PING

See Also:

Constant Field Values

PACKET_PONG

public static final java.lang.String PACKET_PONG

See Also:

Constant Field Values

eventChannel

public java.lang.String eventChannel

requestChannel

public java.lang.String requestChannel

responseChannel

public java.lang.String responseChannel

discoverBroadcastChannel

public java.lang.String discoverBroadcastChannel

discoverChannel

public java.lang.String discoverChannel

infoBroadcastChannel

public java.lang.String infoBroadcastChannel

infoChannel

public java.lang.String infoChannel

disconnectChannel

public java.lang.String disconnectChannel

heartbeatChannel

public java.lang.String heartbeatChannel

pingChannel

public java.lang.String pingChannel

pongChannel

public java.lang.String pongChannel

namespace

protected java.lang.String namespace

prefix

protected java.lang.String prefix

nodeID

protected java.lang.String nodeID

heartbeatInterval

protected int heartbeatInterval

Heartbeat sending period in SECONDS.

heartbeatTimeout

protected int heartbeatTimeout

Heartbeat timeout in SECONDS.

offlineTimeout

protected int offlineTimeout

How long keep information in registry about the offline nodes (SECONDS).

subscriptionTimeout

protected int subscriptionTimeout

Timeout of channel subscriptions (SECONDS).

preferHostname

protected boolean preferHostname

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.

debug

protected boolean debug

serializer

protected Serializer serializer

executor

protected java.util.concurrent.ExecutorService executor

scheduler

protected java.util.concurrent.ScheduledExecutorService scheduler

registry

protected ServiceRegistry registry

eventbus

protected Eventbus eventbus

monitor

protected Monitor monitor

uid

protected UidGenerator uid

heartBeatTimer

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

Cancelable "Heart Beat" timer

checkTimeoutTimer

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

Cancelable "Check Activities / Infos" timer

nodes

protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,NodeDescriptor> nodes

infoScheduled

protected final java.util.concurrent.atomic.AtomicBoolean infoScheduled

Constructor Detail

Transporter

public Transporter()

Transporter

public Transporter(Serializer serializer)

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Initializes transporter instance.

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

channel

protected java.lang.String channel(java.lang.String cmd,
                                   java.lang.String nodeID)

connect

public abstract void connect()

connected

protected void connected()

connected

protected void connected(boolean waitFor)

stopped

public void stopped()

Closes transporter.

Overrides:

stopped in class MoleculerComponent

createPingPacket

public io.datatree.Tree createPingPacket(java.lang.String id)

createRequestPacket

public io.datatree.Tree createRequestPacket(Context ctx)
                                     throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

publish

public void publish(java.lang.String cmd,
                    java.lang.String nodeID,
                    io.datatree.Tree message)

publish

public abstract void publish(java.lang.String channel,
                             io.datatree.Tree message)

subscribe

public io.datatree.Promise subscribe(java.lang.String cmd,
                                     java.lang.String nodeID)

subscribe

public abstract io.datatree.Promise subscribe(java.lang.String channel)

received

protected void received(java.lang.String channel,
                        byte[] message)

Process incoming message later (in a new Runnable or JoinForkTask).

Parameters:

channel - incoming channel

message - incoming message

processReceivedMessage

protected void processReceivedMessage(java.lang.String channel,
                                      byte[] message)

Process incoming message directly (without new Task).

Parameters:

channel - incoming channel

message - incoming message

updateNodeInfo

protected void updateNodeInfo(java.lang.String sender,
                              io.datatree.Tree info)
                       throws java.lang.Exception

Throws:

java.lang.Exception

broadcastNodeConnected

protected void broadcastNodeConnected(io.datatree.Tree info,
                                      boolean reconnected)

broadcastNodeUpdated

protected void broadcastNodeUpdated(io.datatree.Tree info)

broadcastNodeDisconnected

protected void broadcastNodeDisconnected(io.datatree.Tree info,
                                         boolean unexpected)

broadcastInfoPacket

public void broadcastInfoPacket()

sendDiscoverPacket

protected void sendDiscoverPacket(java.lang.String channel)

sendInfoPacket

protected void sendInfoPacket(java.lang.String channel)

sendHeartbeatPacket

protected void sendHeartbeatPacket()

sendDisconnectPacket

protected void sendDisconnectPacket()

sendPongPacket

protected void sendPongPacket(java.lang.String channel,
                              io.datatree.Tree data)

checkTimeouts

protected void checkTimeouts()

getCpuUsage

public int getCpuUsage(java.lang.String nodeID)

getLastHeartbeatTime

public long getLastHeartbeatTime(java.lang.String nodeID)

isOnline

public boolean isOnline(java.lang.String nodeID)

getAllNodeIDs

public java.util.Set<java.lang.String> getAllNodeIDs()

getDescriptor

public io.datatree.Tree getDescriptor(java.lang.String nodeID)

getAddress

public RemoteAddress getAddress(java.lang.String nodeID)

error

protected void error(java.lang.Throwable error)

Any I/O error occured. Implementation-specific error handling goes here (reconnection, etc.).

Parameters:

error - I/O error

getSerializer

public Serializer getSerializer()

setSerializer

public void setSerializer(Serializer serializer)

getHeartbeatInterval

public int getHeartbeatInterval()

setHeartbeatInterval

public void setHeartbeatInterval(int heartbeatInterval)

getHeartbeatTimeout

public int getHeartbeatTimeout()

setHeartbeatTimeout

public void setHeartbeatTimeout(int heartbeatTimeout)

isDebug

public boolean isDebug()

setDebug

public void setDebug(boolean debug)

getOfflineTimeout

public int getOfflineTimeout()

setOfflineTimeout

public void setOfflineTimeout(int offlineTimeout)

getNamespace

public java.lang.String getNamespace()

setNamespace

public void setNamespace(java.lang.String namespace)

getPrefix

public java.lang.String getPrefix()

setPrefix

public void setPrefix(java.lang.String prefix)

isPreferHostname

public boolean isPreferHostname()

setPreferHostname

public void setPreferHostname(boolean preferHostname)

getSubscriptionTimeout

public int getSubscriptionTimeout()

setSubscriptionTimeout

public void setSubscriptionTimeout(int subscriptionTimeout)