services.moleculer.transporter

Class AmqpTransporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

services.moleculer.transporter.AmqpTransporter

All Implemented Interfaces:

MetricConstants, MoleculerLifecycle

public class AmqpTransporter
extends Transporter

AMQP Transporter based on RabbitMQ's AMQP client API. AMQP provides a platform-agnostic method for ensuring information is safely transported between applications, among organizations, within mobile infrastructures, and across the Cloud. Usage:

 ServiceBroker broker = ServiceBroker.builder().nodeID("node1").transporter(new AmqpTransporter("localhost")).build();
 

Required dependency:

// https://mvnrepository.com/artifact/com.rabbitmq/amqp-client
compile group: 'com.rabbitmq', name: 'amqp-client', version: '5.8.0'

See Also:

TcpTransporter, RedisTransporter, NatsTransporter, NatsStreamingTransporter, MqttTransporter, JmsTransporter, KafkaTransporter, InternalTransporter

Field Summary

Fields

Modifier and Type	Field and Description
protected com.rabbitmq.client.Channel	channel
protected com.rabbitmq.client.Connection	client
protected java.util.Map<java.lang.String,java.lang.Object>	exchangeProperties
protected java.lang.String	exchangeType
protected boolean	exclusive
protected com.rabbitmq.client.ConnectionFactory	factory
protected boolean	immediate
protected boolean	internal
protected boolean	mandatory
protected com.rabbitmq.client.AMQP.BasicProperties	messageProperties
protected java.lang.String	password
protected java.util.Map<java.lang.String,java.lang.Object>	queueProperties
protected com.rabbitmq.client.SslContextFactory	sslContextFactory
protected java.util.concurrent.atomic.AtomicBoolean	started
protected java.lang.String	url
protected java.lang.String	username

Fields inherited from class services.moleculer.transporter.Transporter

checkTimeoutTimer, counterTransporterPacketsReceivedBytes, counterTransporterPacketsReceivedTotal, counterTransporterPacketsSentBytes, counterTransporterPacketsSentTotal, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, executor, gaugeTransitConnected, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, infoScheduledAt, instanceID, lastReceivedMessageAt, metrics, 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, protocolVersion, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializer

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.metrics.MetricConstants

MOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC

Constructor Summary

Constructors

Constructor and Description
AmqpTransporter()
AmqpTransporter(java.lang.String url)
AmqpTransporter(java.lang.String username, java.lang.String password, com.rabbitmq.client.SslContextFactory sslContextFactory, java.lang.String url)

Method Summary

Modifier and Type	Method and Description
void	connect()
protected void	disconnect()
protected void	error(java.lang.Throwable cause) Any I/O error occurred.
java.util.Map<java.lang.String,java.lang.Object>	getExchangeProperties()
java.lang.String	getExchangeType()
com.rabbitmq.client.ConnectionFactory	getFactory()
com.rabbitmq.client.AMQP.BasicProperties	getMessageProperties()
java.lang.String	getPassword()
java.util.Map<java.lang.String,java.lang.Object>	getQueueProperties()
com.rabbitmq.client.SslContextFactory	getSslContextFactory()
java.lang.String	getUrl()
java.lang.String	getUsername()
boolean	isExclusive()
boolean	isImmediate()
boolean	isInternal()
boolean	isMandatory()
void	publish(java.lang.String channel, io.datatree.Tree message)
protected void	reconnect()
void	setExchangeProperties(java.util.Map<java.lang.String,java.lang.Object> exchangeProperties)
void	setExchangeType(java.lang.String exchangeType)
void	setExclusive(boolean exclusive)
void	setFactory(com.rabbitmq.client.ConnectionFactory factory)
void	setImmediate(boolean immediate)
void	setInternal(boolean internal)
void	setMandatory(boolean mandatory)
void	setMessageProperties(com.rabbitmq.client.AMQP.BasicProperties messageProperties)
void	setPassword(java.lang.String password)
void	setQueueProperties(java.util.Map<java.lang.String,java.lang.Object> queueProperties)
void	setSslContextFactory(com.rabbitmq.client.SslContextFactory sslContextFactory)
void	setUrl(java.lang.String url)
void	setUsername(java.lang.String username)
void	stopped() Closes transporter.
io.datatree.Promise	subscribe(java.lang.String channel)

Methods inherited from class services.moleculer.transporter.Transporter

broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, broadcastTransporterConnected, broadcastTransporterDisconnected, channel, checkTimeouts, connected, connected, createPingPacket, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getInstanceID, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, processReceivedMessage, publish, received, scheduleInfoPacket, 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

username

protected java.lang.String username

password

protected java.lang.String password

url

protected java.lang.String url

sslContextFactory

protected com.rabbitmq.client.SslContextFactory sslContextFactory

factory

protected com.rabbitmq.client.ConnectionFactory factory

mandatory

protected boolean mandatory

immediate

protected boolean immediate

exclusive

protected boolean exclusive

internal

protected boolean internal

exchangeType

protected java.lang.String exchangeType

messageProperties

protected com.rabbitmq.client.AMQP.BasicProperties messageProperties

queueProperties

protected java.util.Map<java.lang.String,java.lang.Object> queueProperties

exchangeProperties

protected java.util.Map<java.lang.String,java.lang.Object> exchangeProperties

client

protected com.rabbitmq.client.Connection client

channel

protected com.rabbitmq.client.Channel channel

started

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

Constructor Detail

AmqpTransporter

public AmqpTransporter()

AmqpTransporter

public AmqpTransporter(java.lang.String url)

AmqpTransporter

public AmqpTransporter(java.lang.String username,
                       java.lang.String password,
                       com.rabbitmq.client.SslContextFactory sslContextFactory,
                       java.lang.String url)

Method Detail

connect

public void connect()

Specified by:

connect in class Transporter

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 occurred. Implementation-specific error handling goes here (reconnection, etc.).

Overrides:

error in class Transporter

Parameters:

cause - I/O error

stopped

public void stopped()

Closes transporter.

Specified by:

stopped in interface MoleculerLifecycle

Overrides:

stopped in class Transporter

subscribe

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

Specified by:

subscribe in class Transporter

publish

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

Specified by:

publish in class Transporter

getUrl

public java.lang.String getUrl()

setUrl

public void setUrl(java.lang.String url)

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)

getFactory

public com.rabbitmq.client.ConnectionFactory getFactory()

setFactory

public void setFactory(com.rabbitmq.client.ConnectionFactory factory)

isMandatory

public boolean isMandatory()

setMandatory

public void setMandatory(boolean mandatory)

isImmediate

public boolean isImmediate()

setImmediate

public void setImmediate(boolean immediate)

getMessageProperties

public com.rabbitmq.client.AMQP.BasicProperties getMessageProperties()

setMessageProperties

public void setMessageProperties(com.rabbitmq.client.AMQP.BasicProperties messageProperties)

getSslContextFactory

public com.rabbitmq.client.SslContextFactory getSslContextFactory()

setSslContextFactory

public void setSslContextFactory(com.rabbitmq.client.SslContextFactory sslContextFactory)

getExchangeType

public java.lang.String getExchangeType()

setExchangeType

public void setExchangeType(java.lang.String exchangeType)

isExclusive

public boolean isExclusive()

setExclusive

public void setExclusive(boolean exclusive)

getQueueProperties

public java.util.Map<java.lang.String,java.lang.Object> getQueueProperties()

setQueueProperties

public void setQueueProperties(java.util.Map<java.lang.String,java.lang.Object> queueProperties)

getExchangeProperties

public java.util.Map<java.lang.String,java.lang.Object> getExchangeProperties()

setExchangeProperties

public void setExchangeProperties(java.util.Map<java.lang.String,java.lang.Object> exchangeProperties)

isInternal

public boolean isInternal()

setInternal

public void setInternal(boolean internal)