queue - RabbitMQ Shovel Message Rate -
i have queue following parameters:
- x-ha-policy: all
- durable: true
there static shovel configured process queue , server set destination. shovel configuration:
{sources, [ {broker, "amqp://web:web@thisserver.spc/%2f"} ]}, {destinations, [ {broker, "amqp://web:web@remoteserver.spc/%2f"} ]}, {queue, <<"queuename">>}, {prefetch_count, 10}, {publish_fields, [ {exchange, <<"exchangename">>} ]}, {reconnect_delay, 5}
my problem deliver / , ack rates never go on 50/s "queuename" queue, therefore causing huge build-up (7 million) in queue.
i wonder if changing prefetch_count increase message rate?
also "ack required" enabled consumer of queue. default value is: on_confirm. if messages forced acknowledged, limit message rates?
there few things going on here affect message rates including network speed, message size, memory size rabbitmq broker, etc. can change pre-fetch count , make higher, some. due high number of messages in queue may reaching flow control, check out article.
Comments
Post a Comment