From 4e5d55b7e2220f0ada1d0a4435f12a5f26c851b7 Mon Sep 17 00:00:00 2001 From: Manas Ranjan Dikshit Date: Sun, 23 Mar 2025 11:23:12 +0530 Subject: [PATCH] Update AmqpConfig.java --- partials/AmqpConfig.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/partials/AmqpConfig.java b/partials/AmqpConfig.java index d9e1956cb..fce356238 100644 --- a/partials/AmqpConfig.java +++ b/partials/AmqpConfig.java @@ -55,13 +55,13 @@ public class Config { return new {{type}}({{varName}}Exchange, {% if channel.binding('amqp').exchange.durable %}{{channel.binding('amqp').exchange.durable}}{% else %}true{% endif%}, {% if channel.binding('amqp').exchange.exclusive %}{{channel.binding('amqp').exchange.exclusive}}{% else %}false{% endif%}); } - {% if channel.binding('amqp') and channel.binding('amqp').queue %} + {% if channel.binding('amqp') and channel.binding('amqp').queue %} @Bean public Binding binding{{name | upperFirst}}({{type}} {{name}}Exchange, Queue {{name}}Queue) { - return BindingBuilder.bind({{name}}Queue).to({{name}}Exchange){% if channel.binding('amqp').exchange.type !== 'fanout' %}.with({{varName}}RoutingKey){% endif %}; + return BindingBuilder.bind({{name}}Queue).to({{name}}Exchange) + {% if channel.binding('amqp').exchange.type !== 'fanout' %}.with({{varName}}RoutingKey)}{% endif %}; } - {% endif %}{% endif %} - +{% endif %} {% if channel.binding('amqp') and channel.binding('amqp').queue %} @Bean public Queue {{name}}Queue() {