Circut Breaker

[wodka]

Hi, I'd like to implement a way to break the consumption of messages if certain conditions are met.

RabbitMQ itself only allows this if either the consumer is canceled.

Reasons for doing this could be:

• High error rates
• some known problem why a certain consumer cannot process right now

For us I'd also like to have a way for "admins" to pause / unpause queues.

Ideally we could do this with the following 2 extensions:

Add a hook for created consumers

@RabbitSubscribe({
  exchange: '...',
  onCreate: (id, consumer, queue) => {
    // register this consumer somewhere, with the id to be able to use ie the connection manager to then pause and continue
  }
})

Add logic to Connection manager to pause and continue

(not sure if connection manager is right for this), AmqpConnection can only cancel the consumer tag... (but for this to work nicely we also need to reconnect properly)

connection: ConnectionManager

connection.pause(id)
connection.continue(id)