framework:
  messenger:
    # Uncomment this (and the failed transport below) to send failed messages to this transport for later handling.
    failure_transport: failed

    transports:
      # https://symfony.com/doc/current/messenger.html#transport-configuration
      generation_execute:
        dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
        options:
          exchange:
            name: maestro_projects
            type: direct
          queues:
            execute_generation:
              binding_keys:
                - execute_generation
        retry_strategy:
          max_retries: "%env(int:MESSENGER_MAX_RETRIES)%"
          delay: 5000
          multiplier: 2
          max_delay: 25000
      generation_notify:
        dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
        options:
          exchange:
            name: maestro_projects
            type: direct
          queues:
            notify_generation:
              binding_keys:
                - notify_generation
        retry_strategy:
          max_retries: "%env(int:MESSENGER_MAX_RETRIES)%"
          delay: 4000
          multiplier: 2
          max_delay: 20000
      generation_push:
        dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
        options:
          exchange:
            name: maestro_projects
            type: direct
          queues:
            push_generation:
              binding_keys:
                - push_generation
        retry_strategy:
          max_retries: "%env(int:MESSENGER_MAX_RETRIES)%"
          delay: 1000
          multiplier: 1
          max_delay: 5000
      user_log_execute_projects:
        dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
        options:
          exchange:
            name: maestro_dam
            type: direct
          queues:
            execute_user_log_projects:
              binding_keys:
                - execute_user_log_projects
      auto_generation_execute:
        dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
        options:
          exchange:
            name: maestro_projects
            type: direct
          queues:
            execute_auto_generation:
              binding_keys:
                - execute_auto_generation
        retry_strategy:
          max_retries: "%env(int:MESSENGER_MAX_RETRIES)%"
          delay: 5000
          multiplier: 2
          max_delay: 25000
      failed: "doctrine://projects?queue_name=failed"
      # sync: 'sync://'

    routing:
      # Route your messages to the transports
      App\Application\Message\GenerationExecuteMessage: generation_execute
      App\Application\Message\GenerationNotificationMessage: generation_notify
      Symfony\Component\Mercure\Update: generation_push
      App\Application\Message\UserLogMessage: user_log_execute_projects
      App\Application\Message\AutoGenerationMessage: auto_generation_execute