Simple and minimalistic ZMQ Zyre to SQLite recording and replaying tool.
When asked to record, this program enters the Zyre network, joins all peer groups it discovers (and additional explicitly defined groups, if so desired), and records all SHOUT and WHISPER messages it receives into a table in a SQLite database file.
When asked to replay, this program looks through the specified SQLite database table and collects all peer names of peers that SHOUTed in the recording. Then the program itself spawns all those peers into the Zyre network and uses them to SHOUT all of the recorded messages to appropriate groups while preserving the actual recorded delays between messages (i.e., the replay is real-time and takes as long as the recording took). Please note, that WHISPERs in the recording are ignored during replay.
In the recording database, the message payload (zmsg) is
encoded as a single zframe using zmsg_encode and then
stored as a blob. This can be reversed by loading the blob into a zframe and using zmsg_decode
to decode the original zmsg out of the encoded data. Timestamps are UNIX times in microseconds.
The recorded database table includes a column for pretty-printed variant of the received payload.
This column is populated by a formatter that can be specified depending on which kind of data
serialization your Zyre communications are using. The formatter is used to transform the received
zmsg into a single string that is possibly more human-readable than the raw payload. Examples of
this would be multi-frame messages, messages with binary serializations like Protobuf, etc.
You can easily write your own formatter based on the way you are serializing the messages in your
Zyre communications. Take a look at the example formatters 1string and nstrings.
The following libraries are required to be available to CMake via PkgConfig: