This interceptor consumes messages from one queue and publishes them to another, throttling the message rate using credit based QoS implementation.
koubas / amqp-throttle Goto Github PK
View Code? Open in Web Editor NEWAMQP throttling interceptor (POC)
License: The Unlicense