Read Events from a Queue (ampq/stomp)

[pedrokiefer]

I would like to be able to read incoming events from a queue, instead of http requests. From the code I've read, the queue handler would need to call enqueueWork with a valid CloudEvent.

This feature could be implemented either as new plugin interface with access to the router, or as configurable endpoint with the whole ampq/stomp stack inside event-gateway.

[mthenw]

Hey @pedrokiefer,

thanks for creating the issue. Ability to read events from external systems like AMQP, Kafka, Kinesis is one of the highest priorities in our backlog.

[brianneisler]

Something to look at here is the AMQP transport binding for CloudEvents https://github.com/cloudevents/spec/blob/master/amqp-transport-binding.md

[pedrokiefer]

@mthenw cool! Do you have a draft of the architecture for supporting this? I might have some time to tackle this issue in the next few weeks, and having some guideline would be great.

[mthenw]

@pedrokiefer we are not at this stage yet. We are considering different options (as an external executable, or built-in into Event Gateway binary). I will update this issue once we have more info.