Skip to content

Commit 07acee7

Browse files
committed
Update AmqpConfig.java
1 parent 5d9a334 commit 07acee7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

partials/AmqpConfig.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -55,13 +55,13 @@ public class Config {
5555
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%});
5656
}
5757

58-
{% if channel.binding('amqp') and channel.binding('amqp').queue %}
58+
{% if channel.binding('amqp') and channel.binding('amqp').queue %}
5959
@Bean
6060
public Binding binding{{name | upperFirst}}({{type}} {{name}}Exchange, Queue {{name}}Queue) {
61-
return BindingBuilder.bind({{name}}Queue).to({{name}}Exchange){% if channel.binding('amqp').exchange.type !== 'fanout' %}.with({{varName}}RoutingKey){% endif %};
61+
return BindingBuilder.bind({{name}}Queue).to({{name}}Exchange)
62+
{% if channel.binding('amqp').exchange.type !== 'fanout' %}.with({{varName}}RoutingKey)}{% endif %};
6263
}
63-
{% endif %}{% endif %}
64-
64+
{% endif %}
6565
{% if channel.binding('amqp') and channel.binding('amqp').queue %}
6666
@Bean
6767
public Queue {{name}}Queue() {

0 commit comments

Comments
 (0)