Skip to content

Tag: rabbitmq

RabbitMQ Streams

Using this document as a reference: https://blog.rabbitmq.com/posts/2021/07/rabbitmq-streams-first-application I have created a stream in RabbitMQ and added 1 million messages to it. I’m trying to read back all of the messages in the stream by doing the following: However, this will only print up to mes…

Gatling JMS scenario does not terminate

I am trying to loadtest a simple request/reply scenario over a rabbitmq broker. This scenario sends a simple text message to the defined queue and then wait on the defined replyQueue for an answer. On the other side of the request queue is simple message listener that reads the JMSReplyTo field and sends a me…

Rabbit MQ doesn’t flush acks?

The problem appeared in logs: Consumer failed to start in 60000 milliseconds; does the task executor have enough threads to support the container concurrency? We try to open handlers for like 50 queues dynamically by SimpleMessageListenerContainer.addQueueNames(), then application is started. It consumes some…