RabbitMQ queues pile up with messages over a period of time even though there are listeners associated with those queues -
i have situation in rabbitmq setup. scenario below,
setup:
- there 2 virtual machines involved.
- both vms sending 25mb size messages every 7 seconds in loop.
- there shovels setup transmitting messages between machines.
- both machines have listeners consume messages sent other machine.
- listeners consume messages , comes out. there no processing involved @ listener side.
- there rabbitmq broker ssl enabled.
- i using spring rabbitmq.
- i using simplemessagelistenercontainer listening.
my issues:
over period of time, after 1.5 days of continuous message exchange, there accumulation of messages in queues.
the listeners consumption rate diminishes on period of time , messages pile in queue.
some of messages accumulated in queue in unacked state.
things want try:
- increase no. of listeners queue.
- increase prefetch count listener.
my question
- why messages got accumulated on period of time.
- was there network disturbance in between. need add parameters listeners tackle network disturbances.
please guide me here. need in fine tuning setup make more robust.
it difficult here debug application.
consumption rate diminishes on period of time
that symptom of application rather messaging system or framework. start there.
was there network disturbance in between.
with recent versions of rabbitmq, heartbeats enabled default such "disturbances" should detected ok.
Comments
Post a Comment