|
@@ -18,31 +18,31 @@ old_sound_rabbit_mq:
|
|
|
|
|
|
#requires php_sockets.dll
|
|
|
# use_socket: true # default false
|
|
|
-
|
|
|
+
|
|
|
producers:
|
|
|
flowdat_tasklogger:
|
|
|
connection: default
|
|
|
exchange_options: {name: 'send', type: topic}
|
|
|
service_alias: fd_tasklogger_service # no alias by default
|
|
|
-
|
|
|
+
|
|
|
command_producer:
|
|
|
connection: default
|
|
|
exchange_options: {name: 'command', type: topic}
|
|
|
service_alias: command_producer_service # no alias by default
|
|
|
-
|
|
|
+
|
|
|
consumers:
|
|
|
flowdat_tasklogger:
|
|
|
connection: default
|
|
|
exchange_options: {name: 'send', type: topic}
|
|
|
- queue_options: {name: 'send', routing_keys : ["%env(AMQP_KEY)%"]}
|
|
|
+ queue_options: {name: "send.%env(AMQP_KEY)%", routing_keys : ["%env(AMQP_KEY)%"]}
|
|
|
callback: flowdat_tasklogger_service # sf service id
|
|
|
-
|
|
|
+
|
|
|
command_consumer:
|
|
|
connection: default
|
|
|
exchange_options: {name: 'command', type: topic}
|
|
|
queue_options: {name: "command.%env(AMQP_KEY)%", routing_keys : ["%env(AMQP_KEY)%"]}
|
|
|
callback: command_consumer_service # sf service id
|
|
|
-
|
|
|
+
|
|
|
log_consumer:
|
|
|
connection: default
|
|
|
exchange_options: {name: 'log', type: topic}
|