Skip to content
Advertisement

Tag: amqp-client

Temporarily stop consuming RabbitMQ messages and resume later

I use Java’s rabbitmq-client (https://mvnrepository.com/artifact/com.rabbitmq/amqp-client) and I need to implement the following scenario: While receiving Rabbit messages, I may need to pause Rabbitmq consumption from particular queues if I suspect that all awaiting data will not fit in memory. After I processed some messages, I need to open consumption again for the following set of messages. Repeat as needed. What

Advertisement