Message rates stop at 25 msg/s about rabbitmqbundle HOT 6 CLOSED

I'll have to look into more details into this… but as a quick answer I've had a latency of 1 message taking 2ms for an RPC request. So something must be missconfigured

from rabbitmqbundle.

I find exchange_declare() may be the key. (RabbitMq/Producer.php, line:11)
When move it out of the publish() method, I can get about 1500 msg/s.

from rabbitmqbundle.

You are right… that line shouldn't be there. I will try to understand why I put it there in the first place.

from rabbitmqbundle.

maybe this willl helpful

public function exchangeDeclare()
{
    $this->ch->exchange_declare($this->exchangeOptions['name'], $this->exchangeOptions['type'], false, true, false);
}

public function publish($msgBody, $routingKey = '')
{
    $msg = new \AMQPMessage($msgBody, array('content_type' => 'text/plain', 'delivery_mode' => 2));
    $this->ch->basic_publish($msg, $this->exchangeOptions['name'], $routingKey);
}

from rabbitmqbundle.

Fixed. Please confirm. Later I will add my benchmark code.

from rabbitmqbundle.

Got 1700+ msg/s. Event performance is better.

from rabbitmqbundle.