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

Popular posts from this blog

javascript - Karma not able to start PhantomJS on Windows - Error: spawn UNKNOWN -

c# - Display ASPX Popup control in RowDeleteing Event (ASPX Gridview) -

Nuget pack csproj using nuspec -