<div>š</div><div>I run RabbitMQ on my local machine and the consumer receives messages with the speed about 2500 messages per second. Is there the way to do it faster?</div><div>š</div><div>here is my consumer code:</div><div>š</div><div><div>package com.mdnaRabbit.worker;</div><div>š</div><div>import java.io.IOException;</div><div>import java.util.concurrent.ExecutorService;</div><div>import java.util.concurrent.Executors;</div><div>š</div><div>import com.rabbitmq.client.ConnectionFactory;</div><div>import com.rabbitmq.client.Connection;</div><div>import com.rabbitmq.client.Channel;</div><div>import com.rabbitmq.client.QueueingConsumer;</div><div>import com.mdnaRabbit.worker.data.Data;</div><div>š</div><div>š</div><div>public class App {</div><div>š</div><div>š š private static final String TASK_QUEUE_NAME = "task_queue";</div><div>š š private static int i = 0;</div><div>š š public static void main (String[] argv) throws IOException,InterruptedException{</div><div>š</div><div>š š š š ExecutorService threader = Executors.newFixedThreadPool(10);</div><div>š š š š ConnectionFactory factory = new ConnectionFactory();</div><div>š</div><div>š š š š factory.setHost("localhost");</div><div>š</div><div>š š š š Connection connection = factory.newConnection(threader);</div><div>š š š š final Channel channel = connection.createChannel();</div><div>š</div><div>š š š š channel.queueDeclare(TASK_QUEUE_NAME, true, false, false, null);</div><div>š š š š System.out.println(" [*] Waiting for messages. To exit press CTRL+C");</div><div>š</div><div>š š š š channel.basicQos(10);</div><div>š</div><div>š š š š final QueueingConsumer consumer = new QueueingConsumer(channel);</div><div>š š š š channel.basicConsume(TASK_QUEUE_NAME, false, consumer);</div><div>š</div><div>š š š š while (true){</div><div>š</div><div>š š š š š š š š try {QueueingConsumer.Delivery delivery = consumer.nextDelivery();</div><div>š š š š š š š š š š Data mess = Data.fromBytes(delivery.getBody());</div><div>š š š š š š š š š š System.out.println(" [" + š+(i++) +"] Received " + mess.getHeader());</div><div>š š š š š š š š š š channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);</div><div>š š š š š š š š }catch (Exception e){</div><div>š š š š š š š š š š e.printStackTrace();</div><div>š š š š š š š š }</div><div>š š š š }</div><div>š š }</div><div>}</div></div><div>š</div><div>š</div><div>-- <br />σ ΥΧΑΦΕΞΙΕΝ, ξΙΛΙΤΙΞ νΙΘΑΙΜ</div>