application.yml

{%- set hasSubscribe = false -%}
{%- set hasPublish = false -%}
{%- for channelName, channel in asyncapi.channels() -%}
    {%- if channel.hasPublish() -%}
        {%- set hasPublish = true -%}
    {%- endif -%}
    {%- if channel.hasSubscribe() -%}
        {%- set hasSubscribe = true -%}
    {%- endif -%}
{%- endfor -%}
{%- for serverName, server in asyncapi.servers() %}{% if server.protocol() == 'amqp' %}
amqp:
  broker: {% for line in server.description() | splitByLines %}
    # {{line | safe}}{% endfor %}
    host: {{server.url() | replace(':{port}', '') }}
    port: {% if server.variable('port') %}{{server.variable('port').defaultValue()}}{% endif %}
    username:
    password:
  exchange:
  {% for channelName, channel in asyncapi.channels() %}
    {% if channel.hasSubscribe() and channel.subscribe().binding('amqp') %}
    {{channelName}}: {{channel.subscribe().binding('amqp').exchange.name}}
    {% endif %}
  {% endfor %}
  queue:
  {% for channelName, channel in asyncapi.channels() %}
    {% if channel.hasPublish() and channel.publish().binding('amqp') %}
    {{channelName}}: {{channel.publish().binding('amqp').queue.name}}
    {% endif %}
  {% endfor %}
{% endif %}
{% if server.protocol() == 'mqtt' %}
mqtt:
  broker: {% for line in server.description() | splitByLines %}
    # {{line | safe}}{% endfor %}
    address: {% if server.variable('port') %}{{server.url() | replace('{port}', server.variable('port').defaultValue())}}{% else %}{{server.url()}}{% endif %}
    username:
    password:
    {% if server.binding('mqtt') and server.binding('mqtt').clientId %}clientId: {{server.binding('mqtt').clientId}}{% endif %}
    {% if server.binding('mqtt') and server.binding('mqtt').cleanSession | isDefined %}cleanSession: {{server.binding('mqtt').cleanSession}}{% endif %}
    {% if server.binding('mqtt') and server.binding('mqtt').lastWill %}lastWill:
      topic: {{server.binding('mqtt').lastWill.topic}}
      message: {{server.binding('mqtt').lastWill.message}}
      qos: {{server.binding('mqtt').lastWill.qos}}
      retain: {{server.binding('mqtt').lastWill.retain}}
    {% endif %}
    timeout:
      completion: {{params.completionTimeout}}
      disconnection: {{params.disconnectionTimeout}}
      connection: {{params.connectionTimeout}}
      {% if server.binding('mqtt') and server.binding('mqtt').keepAlive | isDefined %}keepAlive: {{server.binding('mqtt').keepAlive}}{% endif %}
  topic:
    {% for channelName, channel in asyncapi.channels() %}{% if channel.hasPublish() %}
    {{channel.publish().id() | camelCase}}: {{channelName}}
    {% elif channel.hasSubscribe() %}
    {{channel.subscribe().id() | camelCase}}: {{channelName}}
    {% endif %}{% endfor %}
{% endif %}{% endfor %}
{%- if asyncapi | isProtocol('kafka') %}
spring:
  kafka: {% for serverName, server in asyncapi.servers() %}
    # - {{serverName}} in {{server.url()}} : {% for line in server.description() | splitByLines %}
    # {{line | safe}}{% endfor %}{% endfor %}
    bootstrap-servers: {% for serverName, server in asyncapi.servers() %}{% if server.variable('port') %}{{server.url() | replace('{port}', server.variable('port').defaultValue())}}{% else %}{{server.url()}}{% endif %}{% if not loop.last %},{% endif %}{% endfor %}
  {%- if hasPublish %}
    listener:
      poll-timeout: {{params.listenerPollTimeout}}
      concurrency: {{params.listenerConcurrency}}
  {% endif %}
{% endif %}