Changes for version 0.02_04 - 2021-05-27

  • Use MQTT 5 instead of STOMP as underlying protocol

Documentation

Manage worker pools
Print last log entries generated by worker pools
Gracefully restart remote pool of workers
Display real-time performance metrics of running workers

Modules

Framework for building applications with a microservices architecture
Make RPC calls through message bus
Read configuration files
Representation of JSON-RPC objects
Access to request auth headers
Representation of a JSON-RPC error.
Representation of a JSON-RPC notification.
Representation of a JSON-RPC request.
Representation of a JSON-RPC response.
Default logger used by worker processes.
A lightweight asynchronous MQTT 5.0 client.
Buffer log entries
Route messages between buses
Route messages between backend and frontend
Handle unserviced job queues
Worker pool supervisor.
Worker pool supervisor.
Base class for creating services
Locally mirrored shared cache
Manage worker pools
Daemonize processes

Provides

in lib/Beekeeper/Service/ToyBroker/Worker.pm
in lib/Beekeeper/Service/ToyBroker/Worker.pm
in lib/Beekeeper/Service/ToyBroker/Worker.pm
in lib/Beekeeper/Service/ToyBroker/Worker.pm

Examples