|
|
|
@ -141,7 +141,7 @@ public final class RabbitAutoConfiguration { |
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
@Bean |
|
|
|
@ConditionalOnMissingBean |
|
|
|
@ConditionalOnMissingBean |
|
|
|
public RabbitTemplateConfigurer rabbitTemplateConfigurer(RabbitProperties properties, |
|
|
|
RabbitTemplateConfigurer rabbitTemplateConfigurer(RabbitProperties properties, |
|
|
|
ObjectProvider<MessageConverter> messageConverter, |
|
|
|
ObjectProvider<MessageConverter> messageConverter, |
|
|
|
ObjectProvider<RabbitTemplateRetrySettingsCustomizer> retrySettingsCustomizers) { |
|
|
|
ObjectProvider<RabbitTemplateRetrySettingsCustomizer> retrySettingsCustomizers) { |
|
|
|
RabbitTemplateConfigurer configurer = new RabbitTemplateConfigurer(properties); |
|
|
|
RabbitTemplateConfigurer configurer = new RabbitTemplateConfigurer(properties); |
|
|
|
@ -153,7 +153,7 @@ public final class RabbitAutoConfiguration { |
|
|
|
@Bean |
|
|
|
@Bean |
|
|
|
@ConditionalOnSingleCandidate(ConnectionFactory.class) |
|
|
|
@ConditionalOnSingleCandidate(ConnectionFactory.class) |
|
|
|
@ConditionalOnMissingBean(RabbitOperations.class) |
|
|
|
@ConditionalOnMissingBean(RabbitOperations.class) |
|
|
|
public RabbitTemplate rabbitTemplate(RabbitTemplateConfigurer configurer, ConnectionFactory connectionFactory, |
|
|
|
RabbitTemplate rabbitTemplate(RabbitTemplateConfigurer configurer, ConnectionFactory connectionFactory, |
|
|
|
ObjectProvider<RabbitTemplateCustomizer> customizers) { |
|
|
|
ObjectProvider<RabbitTemplateCustomizer> customizers) { |
|
|
|
RabbitTemplate template = new RabbitTemplate(); |
|
|
|
RabbitTemplate template = new RabbitTemplate(); |
|
|
|
configurer.configure(template, connectionFactory); |
|
|
|
configurer.configure(template, connectionFactory); |
|
|
|
@ -165,7 +165,7 @@ public final class RabbitAutoConfiguration { |
|
|
|
@ConditionalOnSingleCandidate(ConnectionFactory.class) |
|
|
|
@ConditionalOnSingleCandidate(ConnectionFactory.class) |
|
|
|
@ConditionalOnBooleanProperty(name = "spring.rabbitmq.dynamic", matchIfMissing = true) |
|
|
|
@ConditionalOnBooleanProperty(name = "spring.rabbitmq.dynamic", matchIfMissing = true) |
|
|
|
@ConditionalOnMissingBean |
|
|
|
@ConditionalOnMissingBean |
|
|
|
public AmqpAdmin amqpAdmin(ConnectionFactory connectionFactory) { |
|
|
|
AmqpAdmin amqpAdmin(ConnectionFactory connectionFactory) { |
|
|
|
return new RabbitAdmin(connectionFactory); |
|
|
|
return new RabbitAdmin(connectionFactory); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -179,7 +179,7 @@ public final class RabbitAutoConfiguration { |
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
@Bean |
|
|
|
@ConditionalOnSingleCandidate(RabbitTemplate.class) |
|
|
|
@ConditionalOnSingleCandidate(RabbitTemplate.class) |
|
|
|
public RabbitMessagingTemplate rabbitMessagingTemplate(RabbitTemplate rabbitTemplate) { |
|
|
|
RabbitMessagingTemplate rabbitMessagingTemplate(RabbitTemplate rabbitTemplate) { |
|
|
|
return new RabbitMessagingTemplate(rabbitTemplate); |
|
|
|
return new RabbitMessagingTemplate(rabbitTemplate); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|