All Classes and Interfaces
Class
Description
Promise-based abstract Redis client.
Interface all Actions.
AMQP Transporter based on RabbitMQ's AMQP client API.
Abstract class for Round-Robin and Random invocation strategies.
Abstract class for Round-Robin and Random invocation strategy factories.
To set up, add the following line to the JVM properties:
-Djava.util.logging.config.file=.
-Djava.util.logging.config.file=.
Serializer with Symmetric Key Encryption.
Custom Moleculer exception class for broker option errors.
BSON Serializer
Binary BSON reader and writer.
Binary BSON reader and writer.
Cache annotation to set the caching policy of Actions.
Base superclass of all Cacher implementations.
Calling options (timeout, target nodeID, number of retries).
CBOR Serializer
CBOR is based on the wildly successful JSON data model: numbers, strings, arrays, maps (called objects in JSON), and a few values such as false, true, and null.
CBOR is based on the wildly successful JSON data model: numbers, strings, arrays, maps (called objects in JSON), and a few values such as false, true, and null.
Superclass of chainable Serializers.
For internal use only!
Special service invoker with retry logic + circuit breaker.
"Colorized" ANSI logger.
CPU monitor, which detects the current CPU usage via command line.
Common utilities.
"Fake" system monitor, which returns a constant value.
Base superclass of all objects that can send events (eg.
Lowest CPU usage invocation strategy.
Factory of lowest CPU usage strategy.
Default EventBus implementation.
Default service invoker with retry logic.
Default implementation of the Service Registry.
Message compressor / decompressor.
Abstract class of distributed cachers.
Base superclass of all Event Bus implementations.
This Map is optimized for fast building and serialization.
This Tree is optimized for fast building and serialization.
Fast log formatter for AsyncFileLogger.
Filesystem-based transporter.
Custom Moleculer error class for graceful stopping.
Event group.
Fast
UidGenerator, based on nodeID and an atomic sequence number.This is a Transporter that can connect multiple ServiceBrokers running in the
same JVM.
Invalid packet format error.
Amazon ION Serializer
Description: Amazon Ion is a richly-typed, self-describing, hierarchical data serialization format offering interchangeable binary and text representations.
Description: Amazon Ion is a richly-typed, self-describing, hierarchical data serialization format offering interchangeable binary and text representations.
Serializer based on Java Object Serialization
Type safe, but Java-dependent and slower than the JsonSerializer.
Type safe, but Java-dependent and slower than the JsonSerializer.
JSR-107 JCache is a standardized caching API that is Java 6 compatible and
introduced in JEE 8.
JMS Transporter.
JMX-based System Monitor (queries the "SystemCpuLoad" attribute of the
operating-system MXBean).
Generic JSON serializer
JSON (JavaScript Object Notation) is a lightweight data-interchange format.
JSON (JavaScript Object Notation) is a lightweight data-interchange format.
Kafka Transporter.
Interface of all local event listeners.
Event mask matcher (eg.
'Max request call level' error message.
On-heap memory cache.
Moleculer error class for client errors which is not retryable.
Custom Moleculer Exception class.
Custom Moleculer error class for retryable errors.
Runs Service Broker as a standalone Java application (or Windows service).
Moleculer error class for server error which is retryable.
Base superclass of all System Monitor implementations.
MQTT Transporter (eg. for Mosquitto MQTT Server or ActiveMQ Server).
MessagePack serializer
MessagePack is an efficient binary serialization format.
MessagePack is an efficient binary serialization format.
Human readable name of a Moleculer Component (eg.
Nanosec-based pseudorandom invocation strategy.
Factory of nanosec-based pseudorandom invocation strategy.
NATS Transporter.
Lowest network latency strategy.
Factory of lowest network latency strategy.
Node descriptor of all (remote and local) nodes.
The broker contains some internal services to check the health of node or get
broker statistics.
"Null" / empty transporter.
Interface of all packet/stream receivers.
NodeJS compatible streaming API to transfer binary files/content.
Sample service invocation with a stream:
Sample service invocation with a stream:
Promise container of a pending action calls.
Protocol version mismatch exception.
'Queue is full' error message.
Redis-based distributed cache.
Promise-based get/set Redis client.
Promise-based pub/sub Redis client.
Redis Transporter.
'Request rejected' error message.
'Request skipped' error message.
'Request timed out' error message.
Round-Robin invocation strategy.
Factory of Round-Robin invocation strategy.
Java Random/SecureRandom-based invocation strategy.
Factory of Java SecureRandom-based invocation strategy.
Attachment of TcpWriter's SelectionKeys.
Base superclass of all data serializer implementations.
Superclass of Moleculer Services.
The ServiceBroker is the main component of Moleculer.
Builder-style ServiceBroker factory.
Base superclass of all Service Invoker implementations.
Promise container of a "waitingForServices" calls.
'Service not available' error message.
'Service not found' error message.
Base superclass of all Service Registry implementations.
Custom Moleculer Exception class for Service schema exceptions.
Sharding invocation strategy.
Sharding invocation strategy factory.
Simple, System.out-based logger.
Smile Serializer
Smile is a computer data interchange format based on JSON.
Smile is a computer data interchange format based on JSON.
Register Spring Components as Moleculer Services in ServiceBroker.
Slower
UidGenerator (but it produces standard UUID's).Base superclass of all Strategy implementations.
Base class of Invocation Strategies.
Mask of the subscribed event (eg.
Packet receiver Thread of the TCP Transporter.
TCP Transporter with optional UDP discovery ("zero configuration") module.
Packet sender Thread of the TCP Transporter.
Time-based standard UUID generator.
Base superclass of all Transporter implementations.
UDP multicast / broadcast discovery service of the TCP Transporter.
Base superclass of all UID Generator implementations.
Action call validation error.
Optional version of a Moleculer Service.
The "Visibility" annotation controls the visibility of an Action.
Fast XORSHIFT-based pseudorandom invocation strategy.
Factory of XORSHIFT-based pseudorandom invocation strategy.
XORSHIFT-based pseudorandom UID generator.