services.moleculer.transporter

Class NatsTransporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

services.moleculer.transporter.NatsTransporter

All Implemented Interfaces:

io.nats.client.DisconnectedCallback, io.nats.client.MessageHandler

public class NatsTransporter
extends Transporter
implements io.nats.client.MessageHandler, io.nats.client.DisconnectedCallback

NATS Transporter. NATS Server is a simple, high performance open source messaging system for cloud native applications, IoT messaging, and microservices architectures (website: https://nats.io).

Required dependency:

// https://mvnrepository.com/artifact/io.nats/jnats
compile group: 'io.nats', name: 'jnats', version: '1.0'

See Also:

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

Field Summary

Fields

Modifier and Type	Field and Description
protected io.nats.client.Connection	client
protected boolean	dontRandomize
protected int	maxPingsOut
protected java.lang.String	password
protected long	pingInterval
protected boolean	secure
protected javax.net.ssl.SSLContext	sslContext
protected java.util.concurrent.atomic.AtomicBoolean	started
protected int	timeout
protected boolean	tlsDebug
protected java.lang.String[]	urls
protected java.lang.String	username
protected boolean	verbose

Fields inherited from class services.moleculer.transporter.Transporter

checkTimeoutTimer, debug, 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, subscriptionTimeout, uid

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
NatsTransporter()
NatsTransporter(java.lang.String... urls)
NatsTransporter(java.lang.String username, java.lang.String password, boolean secure, java.lang.String... urls)

Method Summary

Modifier and Type	Method and Description
void	connect()
protected void	disconnect()
protected void	error(java.lang.Throwable cause) Any I/O error occured.
int	getMaxPingsOut()
java.lang.String	getPassword()
long	getPingInterval()
javax.net.ssl.SSLContext	getSslContext()
int	getTimeout()
java.lang.String[]	getUrls()
java.lang.String	getUsername()
boolean	isDontRandomize()
boolean	isSecure()
boolean	isTlsDebug()
boolean	isVerbose()
void	onDisconnect(io.nats.client.ConnectionEvent event)
void	onMessage(io.nats.client.Message msg)
void	publish(java.lang.String channel, io.datatree.Tree message)
protected void	reconnect()
void	setDontRandomize(boolean dontRandomize)
void	setMaxPingsOut(int maxPingsOut)
void	setPassword(java.lang.String password)
void	setPingInterval(long pingInterval)
void	setSecure(boolean secure)
void	setSslContext(javax.net.ssl.SSLContext sslContext)
void	setTimeout(int timeout)
void	setTlsDebug(boolean tlsDebug)
void	setUrls(java.lang.String[] urls)
void	setUsername(java.lang.String username)
void	setVerbose(boolean verbose)
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, createRequestPacket, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isOnline, isPreferHostname, processReceivedMessage, publish, received, sendDisconnectPacket, sendDiscoverPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, setDebug, 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

username

protected java.lang.String username

password

protected java.lang.String password

secure

protected boolean secure

urls

protected java.lang.String[] urls

sslContext

protected javax.net.ssl.SSLContext sslContext

dontRandomize

protected boolean dontRandomize

maxPingsOut

protected int maxPingsOut

pingInterval

protected long pingInterval

timeout

protected int timeout

tlsDebug

protected boolean tlsDebug

verbose

protected boolean verbose

client

protected io.nats.client.Connection client

started

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

Constructor Detail

NatsTransporter

public NatsTransporter()

NatsTransporter

public NatsTransporter(java.lang.String... urls)

NatsTransporter

public NatsTransporter(java.lang.String username,
                       java.lang.String password,
                       boolean secure,
                       java.lang.String... urls)

Method Detail

connect

public void connect()

Specified by:

connect in class Transporter

onDisconnect

public void onDisconnect(io.nats.client.ConnectionEvent event)

Specified by:

onDisconnect in interface io.nats.client.DisconnectedCallback

disconnect

protected void disconnect()

reconnect

protected void reconnect()

error

protected void error(java.lang.Throwable cause)

Description copied from class: Transporter

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

Overrides:

error in class Transporter

Parameters:

cause - I/O error

stopped

public void stopped()

Closes transporter.

Overrides:

stopped in class Transporter

subscribe

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

Specified by:

subscribe in class Transporter

onMessage

public void onMessage(io.nats.client.Message msg)

Specified by:

onMessage in interface io.nats.client.MessageHandler

publish

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

Specified by:

publish in class Transporter

getUrls

public java.lang.String[] getUrls()

setUrls

public void setUrls(java.lang.String[] urls)

getUsername

public java.lang.String getUsername()

setUsername

public void setUsername(java.lang.String username)

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String password)

getSslContext

public javax.net.ssl.SSLContext getSslContext()

setSslContext

public void setSslContext(javax.net.ssl.SSLContext sslContext)

isSecure

public boolean isSecure()

setSecure

public void setSecure(boolean secure)

isDontRandomize

public boolean isDontRandomize()

setDontRandomize

public void setDontRandomize(boolean dontRandomize)

getMaxPingsOut

public int getMaxPingsOut()

setMaxPingsOut

public void setMaxPingsOut(int maxPingsOut)

getPingInterval

public long getPingInterval()

setPingInterval

public void setPingInterval(long pingInterval)

getTimeout

public int getTimeout()

setTimeout

public void setTimeout(int timeout)

isTlsDebug

public boolean isTlsDebug()

setTlsDebug

public void setTlsDebug(boolean tlsDebug)

isVerbose

public boolean isVerbose()

setVerbose

public void setVerbose(boolean verbose)