Impossible de publier avec succès le message RabbitMQ dans la file d'attente à l'aide d'un nom personnalisé
P粉302484366
P粉302484366 2024-03-26 19:54:35
0
1
437

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粉302484366
P粉302484366

répondre à tous(1)
P粉448346289

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"

Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal