We configure amqp_hosts in different ways for different classes. The issue is that sometimes it is being passed w/o shifting amqp nodes which leads to skewed load among amqp nodes on Services startup/restart.
We have amqp_hosts function for this which returns a string of shifted amqp nodes.
This function should be used everywhere we call classes with rabbit_hosts specified.
We configure amqp_hosts in different ways for different classes. The issue is that sometimes it is being passed w/o shifting amqp nodes which leads to skewed load among amqp nodes on Services startup/restart.
We have amqp_hosts function for this which returns a string of shifted amqp nodes.
This function should be used everywhere we call classes with rabbit_hosts specified.