CERK lets you route your CloudEvents between different different ports. Ports are transport layer bindings over which CloudEvents can be exchanged. It is built with modularity and portability in mind.
CERK comes with a couple of prefabricated components, but implementing custom components is easy.
A good overview is provided on GitHub.
This port publishes and/or subscribe CloudEvents to/from an AMQP broker with protocol version v0.9.1.
The port is implemented with lapin.
The port supports the structured content mode with the JSON event format. However, it does not support the binary content mode.
Helpers for the lapin crate
This is the pointer for the main function to start the port.
This is the main function to start the port.