spring:
    rabbitmq:
      host: localhost
      port: 5672
      username: *****
      password: *****
    cloud:
      stream:
        bindings:
          input: # configure message input
            destination: ${spring.application.name}-queue
            group: ${spring.application.name}-group
            binder: rabbit
            consumer:
              maxAttempts: 1 # enable dlq
              concurrency: 10 # input message consumer concurrency
          output:
            destination: ${spring.application.name}-queue
            group: ${spring.application.name}-group
            binder: rabbit
          fallback:
            destination: ${spring.application.name}-fallback
            group: ${spring.application.name}-group
            binder: rabbit
        binders:
          rabbit:
            type: rabbit
        rabbit:
          bindings:
            output:
              producer:
                declareExchange: false # disable auto declare exchanges because we already declare below
              consumer:
                declareExchange: false
            input:
              producer:
                declareExchange: false
              consumer:
                acknowledgeMode: MANUAL # if handlers are async for example but may be auto for exception driven ack
                republishToDlq : true # republish if failed
                autoBindDlq: true # auto create dlq for input queue
                deadLetterQueueName: dlq # set name for dlq
                delayedExchange: true # enable rabbit delay plugin
                prefetch: 10 # how much messages to fetch for processing
                maxConcurrency: 30 # how much messages to process concurrently