Dev | EventBus and MessageQueue

Jump to bottom

zero edited this page Jan 24, 2019 · 3 revisions

Eventbus is a heart of system, it will help to dispatch message from any publisher to any consumer. Publisher/Consumer can be WebSocket, REST, DAO, Service, external message queue service, e.g: Kafka, MQTT

Rule

Unify message format as EventMessage
Use EventHandler provides listener to response an event
Use EventController to dispatch event

Provider

Kafka

https://github.com/NubeIO/iot-engine/tree/master/core/kafka

MQTT

https://github.com/NubeIO/iot-engine/tree/master/core/mqtt