| [input_{{ name }}] |
| type = "AMQPInput" |
| url = "amqp://{{ values.user }}:{{ values.password }}@{{ values.host }}:{{ values.port }}/{{ values.vhost }}" |
| exchange = "{{ values.exchange }}" |
| exchange_type = "{{ values.exchange_type }}" |
| |
| {% if values.exchange_durability is defined %} |
| exchange_durability = "{{ values.exchange_durability }}" |
| {% endif %} |
| |
| {% if values.exchange_auto_delete is defined %} |
| exchange_auto_delete = "{{ values.exchange_auto_delete }}" |
| {% endif %} |
| |
| {% if values.queue_auto_delete is defined %} |
| queue_auto_delete = {{ values.queue_auto_delete }} |
| {% endif %} |
| |
| queue = "{{ values.queue }}" |
| routing_key = "{{ values.routing_key }}" |
| decoder = "{{ values.decoder }}" |
| splitter = "{{ values.splitter }}" |
| |