<div dir="ltr"><div style>Hello Dear Erlangers!</div><div style><div><br></div><div>I have about 3000 erlang-processes which should send messages to AMQP-queue of destination and receive replies from it.</div></div><div style>

<br></div><div style>The message rate at the moment is about 100 M/s</div><div style>Average message size: 4 Kb</div><div style><br></div><div style>At the moment I have one locally registered gen_server that does all communication with RabbitMQ. It consumes messages and routes them to corresponding worker processes (via gproc). When worker process need to send something, it cast message to RabbitMQ process via local name.  With this approach I see some problems with message consumption speed.</div>

<div style><br></div><div style>What is the right way to interact with RabbitMQ server in Erlang code? Should it be more consumer processes?<br></div><br clear="all"><div><div>Best regards,</div><div>Max</div><br></div>
</div>