services.moleculer.transporter

Class InternalTransporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

services.moleculer.transporter.InternalTransporter

public class InternalTransporter
extends Transporter

This is a Transporter that can connect multiple ServiceBrokers running in the same JVM. The calls are made in separate Threads, so call timeouts can be used. Usage:

 ServiceBroker broker1 = ServiceBroker.builder().nodeID("node1")
 .transporter(new InternalTransporter()).build();
 ServiceBroker broker2 = ServiceBroker.builder().nodeID("node2")
 .transporter(new InternalTransporter()).build();
 

See Also:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	InternalTransporter.Subscriptions
protected static class	InternalTransporter.SubscriptionSet

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.HashSet<java.lang.String>	channels
protected static InternalTransporter.Subscriptions	subscriptions

Fields inherited from class services.moleculer.transporter.Transporter

checkTimeoutTimer, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, executor, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, monitor, namespace, nodeID, nodes, offlineTimeout, PACKET_DISCONNECT, PACKET_DISCOVER, PACKET_EVENT, PACKET_HEARTBEAT, PACKET_INFO, PACKET_PING, PACKET_PONG, PACKET_REQUEST, PACKET_RESPONSE, pingChannel, pongChannel, preferHostname, prefix, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializer

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
InternalTransporter()

Method Summary

Modifier and Type	Method and Description
void	connect()
void	publish(java.lang.String channel, io.datatree.Tree message)
void	stopped() Closes transporter.
io.datatree.Promise	subscribe(java.lang.String channel)

Methods inherited from class services.moleculer.transporter.Transporter

broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, channel, checkTimeouts, connected, connected, createPingPacket, error, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, publish, received, sendClosePacket, sendDataPacket, sendDisconnectPacket, sendDiscoverPacket, sendErrorPacket, sendEventPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, sendRequestPacket, setDebug, setDebugHeartbeats, setHeartbeatInterval, setHeartbeatTimeout, setNamespace, setOfflineTimeout, setPreferHostname, setPrefix, setSerializer, setSubscriptionTimeout, started, subscribe, updateNodeInfo

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

subscriptions

protected static InternalTransporter.Subscriptions subscriptions

channels

protected java.util.HashSet<java.lang.String> channels

Constructor Detail

InternalTransporter

public InternalTransporter()

Method Detail

connect

public void connect()

Specified by:

connect in class Transporter

subscribe

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

Specified by:

subscribe in class Transporter

stopped

public void stopped()

Description copied from class: Transporter

Closes transporter.

Overrides:

stopped in class Transporter

publish

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

Specified by:

publish in class Transporter