The appropriate way to limit memory usage in RabbitMQ is using the vm_memory_high_watermark. You said: I’ve also tried setting the vm_memory_high_watermark to a few different values below the default (of 40%), even as low as 5%. This should work, but it might not be behaving the way you expect. In the logs, you’ll find a … Read more
RabbitMQ is perfect for this situation. You have a number of options to do what you want. I suggest reading the documentation to get a better understanding. I would suggest that you use a topic or direct exchange. Topic is more flexible. It goes like this. Producer code connects to the RabbitMQ Broker and creates … Read more
One of the biggest differences is that REST implies synchronous processing while MQ is more often asynchronous. As you already mentioned, MQ is a way to decouple producer and consumer so that they don’t have to be online at the same time but the system would still be functioning as a whole. If your use … Read more
Add the Channel to the @RabbitListener method… @RabbitListener(queues = “${eventqueue}”) public void receiveMessage(Order order, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws Exception { … } and use the tag in the basicAck, basicReject. EDIT @SpringBootApplication @EnableRabbit public class So38728668Application { public static void main(String[] args) throws Exception { ConfigurableApplicationContext context = SpringApplication.run(So38728668Application.class, args); context.getBean(RabbitTemplate.class).convertAndSend(“”, “so38728668”, “foo”); … Read more
And for the fun the bash version ! #!/bin/bash function encode_password() { SALT=$(od -A n -t x -N 4 /dev/urandom) PASS=$SALT$(echo -n $1 | xxd -ps | tr -d ‘\n’ | tr -d ‘ ‘) PASS=$(echo -n $PASS | xxd -r -p | sha256sum | head -c 128) PASS=$(echo -n $SALT$PASS | xxd -r -p … Read more
You can predefine queues and exchanges without creating own rabbit-mq docker image. Your docker-compose should look like this: rabbit: container_name: rabbitmq-preload-conf image: rabbitmq:3-management volumes: – ./init/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf:ro – ./init/definitions.json:/etc/rabbitmq/definitions.json:ro ports: – “5672:5672” – “15672:15672” In this case rabbitmq.conf and definitions.json files should be in init folder in the same parent folder as docker-compose file rabbitmq.conf file … Read more
Modern versions of RabbitMQ have a delivery acknowledgement timeout: In modern RabbitMQ versions, a timeout is enforced on consumer delivery acknowledgement. This helps detect buggy (stuck) consumers that never acknowledge deliveries. Such consumers can affect node’s on disk data compaction and potentially drive nodes out of disk space. If a consumer does not ack its … Read more
Defaults : Username: guest Password: guest
There are several types of exchanges. The fanout exchange ignores the routing key and sends messages to all queues. But pretty much all other exchange types use the routing key to determine which queue, if any, will receive a message. The tutorials on the RabbitMQ website describes several usecases where different exchange types are useful … Read more