Browse Source

Update config command consumer service

fd-digitaltv 6 years ago
parent
commit
ab7844d40b
1 changed files with 13 additions and 2 deletions
  1. 13 2
      Resources/config/rabbit_mq/config.yml

+ 13 - 2
Resources/config/rabbit_mq/config.yml

@@ -18,6 +18,17 @@ old_sound_rabbit_mq:
 
 
             #requires php_sockets.dll
             #requires php_sockets.dll
 #            use_socket: true # default false
 #            use_socket: true # default false
+        command:
+            host: "%rabbit_mq.host%"
+            port: "%rabbit_mq.port%"
+            user: "%rabbit_mq.user%"
+            password: "%rabbit_mq.password%"
+            vhost: "%rabbit_mq.vhost%"
+            lazy: true
+            connection_timeout: 4
+            read_write_timeout: 4
+            keepalive: false
+            heartbeat: 0
 
 
     producers:
     producers:
         flowdat_tasklogger:
         flowdat_tasklogger:
@@ -26,7 +37,7 @@ old_sound_rabbit_mq:
             service_alias:    fd_tasklogger_service # no alias by default
             service_alias:    fd_tasklogger_service # no alias by default
 
 
         command_producer:
         command_producer:
-            connection:       default
+            connection:       command
             exchange_options: {name: 'command', type: topic}
             exchange_options: {name: 'command', type: topic}
             service_alias:    command_producer_service # no alias by default
             service_alias:    command_producer_service # no alias by default
 
 
@@ -38,7 +49,7 @@ old_sound_rabbit_mq:
             callback:         flowdat_tasklogger_service # sf service id
             callback:         flowdat_tasklogger_service # sf service id
 
 
         command_consumer:
         command_consumer:
-            connection:       default
+            connection:       command
             exchange_options: {name: 'command', type: topic}
             exchange_options: {name: 'command', type: topic}
             queue_options:    {name: "command.%env(AMQP_KEY)%", routing_keys : ["%env(AMQP_KEY)%"]}
             queue_options:    {name: "command.%env(AMQP_KEY)%", routing_keys : ["%env(AMQP_KEY)%"]}
             callback:         command_consumer_service # sf service id
             callback:         command_consumer_service # sf service id