2017-07-07 4 views
0

Je ne trouve pas de bonne configuration pour l'ancien paquetage rabbitmq pour traiter les sujets et les caractères génériques. Tout ce que je veux, c'est un échange unique qui met en file d'attente multiple en utilisant un caractère générique. Soit dit par exemple, j'ai mon nom d'échange user.update, et je veux poster le même message sur user.update.address, user.update.profile pour une stratégie de microservice.rabbitmq-bundle - symfony3 - comment configurer un échange de sujet et des files d'attente?

savez-vous comment configurer dans le fichier de configuration?

Thx pour la lecture.

Répondre

1

Tout simplement parce que vous cherchez

... grande configuration pour le vieux paquet son rabbitmq ...

visite http://www.inanzzz.com/ et recherchez « rabbitmq » qui vous donnera ce que vous voulez pour.

Pour répondre à votre question, vous pouvez utiliser la configuration ci-dessous (je ne l'ai pas testé mais ça devrait aller). Cependant, vous avez encore besoin d'écrire toute la fonctionnalité/classes/consommateurs/producteurs, etc. suivre pour cet exemple: RabbitMQ topic example with symfony including 1 Producer & 1 Exchange & 2 Queue & N Worker & 2 Consumer

old_sound_rabbit_mq: 
    connections: 
     default: 
      host:  %rabbitmq.host% 
      port:  %rabbitmq.port% 
      user:  %rabbitmq.user% 
      password: %rabbitmq.pswd% 
      vhost: /
      lazy:  true 
    producers: 
     user_update_producer: 
      connection:  default 
      exchange_options: { name: user.update, type: topic } 
    consumers: 
     user_update_consumer: 
      connection:  default 
      exchange_options: { name: user.update, type: topic } 
      queue_options: 
       name: user_update_queue 
       routing_keys: 
        - 'user.update.address' 
        - 'user.update.profile' 
      callback:   your_application.consumer.user_update_consumer 

Il est courant: user.update (P) ->user.update (E) ->[user.update.address & user.update.profile] ->user_update_queue (Q)