Warning: bydlokod
RabbitMQ, and a small helper service that invokes http endpoints on new messages in specific queues.
To run the example:
docker run --name rabbitmq -d -p 5672:5672 rabbitmq
go run pusher.go
uvicron service:app --reload
python source.py
Pusher searches for config.yaml in current directory. You can set up triggers like this:
...
triggers:
- source: source-queue
endpoint: url-to-call
sink: sink-queue-or-nothing
- ...
- ...