Я новичок в Spring AMQP и хочу использовать конфигурацию на основе аннотаций как для производителей, так и для потребителей, использующих последнюю версию Spring amqp 1.5.4,
Доступен ли для конфигурации какой-либо псевдо-код, который выполняет логику для создания соединения или @Queue и т. Д.
Вероятно, самый быстрый способ начать - использовать Spring Boot - при загрузке будут созданы все необходимые bean-компоненты (по умолчанию подключаются к localhost, но их можно легко переопределить с помощью свойств).
Вы также можете посмотреть некоторые из Тестовые примеры Spring AMQP.
Создайте класс, аннотированный с помощью @Configuration в Spring Boot, который может предоставить вам определение bean-компонента на основе аннотаций: Вот пример:
@Configuration
public class QueueConfig {
@Bean
public AmqpAdmin amqpAdmin() {
return new RabbitAdmin(connectionFactory());
}
@Bean
public RabbitTemplate rabbitTemplate() {
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
rabbitTemplate.setExchange("myQueue");
return rabbitTemplate;
}
@Bean
Queue rabbitQueue() {
return new Queue(WORKERS_QUEUE_NAME, true, false, false, null);
}
}
