recherche

Maison  >  Questions et réponses  >  le corps du texte

Impossible de publier avec succès le message RabbitMQ dans la file d'attente à l'aide d'un nom personnalisé

Je souhaite publier des messages RabbitMQ dans une file d'attente nommée "vincent.test.rabbitMq". J'essaie d'utiliser Symfony-messenger pour ce faire. Voici mon message :

class TestMessage
{
    private string $value;

    /**
     * @param string $value
     */
    public function __construct(string $value)
    {
        $this->value = $value;
    }

    /**
     * @return string
     */
    public function getValue(): string
    {
        return $this->value;
    }

    /**
     * @param string $value
     */
    public function setValue(string $value): void
    {
        $this->value = $value;
    }


}

Voici mon Messenger.yaml :

framework:
    messenger:

        transports:
            vincent.test.rabbitMq: '%env(RABBITMQ_URL)%'

        routing:
            'App\TestRabbitMQ\TestMessage': vincent.test.rabbitMq

Mais quand je poste quelque chose comme ceci : $this->bus->dispatch(new TestMessage("testmessage123")); Cela créera une file d'attente appelée messages. Si je poste un autre message avec un autre nom, il entre également dans cette file d'attente. Ce que je veux, c'est avoir une file d'attente distincte pour chaque message.

P粉302484366P粉302484366304 Il y a quelques jours490

répondre à tous(1)je répondrai

  • P粉448346289

    P粉4483462892024-03-27 17:23:03

    J'ai trouvé la réponse. Vous ajoutez simplement le nom de la file d'attente à RABBITMQ_URL.

    URL = amqp://guest:guest@localhost:5672/"vhost"/"queuename"

    répondre
    0
  • Annulerrépondre