<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>