Description
This messaging scheme, ezMQ, provides single unified data streaming interface among the EdgeX microservices regardless of underlying Message Queue protocol. It allows the microservices to exchange small size data packets ( actually, we need to define the meaning of 'small size' ) or events with high frequency. So the microservices will be able to stream data inside edge device( in-proc, localhost ) or with the other edge devices over a high speed LAN(Wired/Wireless). For the simultaneous data transmission, multiple microservices can publish to or subscribe from an endpoint which could be an <IP, port> combination or named topics. Microservices The microservices can initiate or stop data flow anytime without worrying about underlying operations. ØMS The microservices will be able to set standard filters over streaming data and EZMQ the ezMQ will take care of applying them in highly optimized manner.
Ø
ØEZMQ The ezMQ will be used as data streaming backbone between different instances of micro-services .
Ø
ØEZMQ will provide the microservices . And the ezMQ provides high speed data serialization/deserialization and Pub / Sub pattern.
Ø
ØEZMQ for effective data transmission. And the ezMQ will also support dynamic topic based data delivery and creation and removal of filters.
Requirements
To be updated.
Design
To be updatedThe attached documents describe the high level design consideration.
Code
https://github.com/mgjeong/protocol-ezmq-go
https://github.com/mgjeong/protocol-ezmq-cpp
https://github.com/mgjeong/protocol-ezmq-javamessaging-zmq
Current status
To be updated.