NOTE: This project has been merged into SmallRye Reactive Messaging
An implementation of a Source connector complying with the (next to be) Eclipse MicroProfile Reactive Messaging specification for source connector.
It largely inspired by SmallRye Reactive Messaging implementation.
It's not a full-blown MQTT server, it's built on top of Vert.x MQTT Server and handles only publish requests of any QoS. The persistence part of the MQTT server is to be handled by the user of this lib.
- Apache Vert.x
- Eclipse MicroProfile CDI and config
- RX Java 2