Приложение Declarabes в Spring с использованием Rabbit MQ - PullRequest
Новая
       17

Приложение Declarabes в Spring с использованием Rabbit MQ

0 голосов
/ 05 мая 2020

Я использую spring aqmp версии 2.2.6 для создания множественной привязки к обмену topi c. Из обсуждения и справочного документа я понял, что могу использовать декларируемые объекты. Spring AMQP: динамическое создание нескольких очередей

Но в моем случае ключи маршрутизации будут указаны в конфигурации приложения в виде запятой. отделены и постоянно растут. Как мне использовать конфигурацию для динамического создания декларируемого bean-компонента. ? ниже - запись конфигурации приложения. rabbit.

1 Ответ

0 голосов
/ 05 мая 2020 
my.queues=foo,bar,baz

Spring может преобразовать это в List<String>. 

@Bean
public Declarables queues(@Value("${my.queues}") List<String> queues) {
    return new Declarables(queues
            .stream()
            .map(q -> new Queue(q))
            .collect(Collectors.toList())
            .toArray(new Queue[0]));
}

EDIT

Для полной картины: 

@Bean
public Declarables declarables(@Value("${my.queues}") List<String> queues,
        @Value("${my.exchange}") String exch, 
        @Value("${my.routing.keys}") List<String> routingKeys) {

    List<Declarable> declarables = queues
                    .stream()
                    .map(q -> new Queue(q))
                    .collect(Collectors.toList());
    declarables.add(new DirectExchange(exch));
    for (int i = 0; i < routingKeys.size(); i++) {
        declarables.add(new Binding(queues.get(i), DestinationType.QUEUE, exch, 
                routingKeys.get(i), null));
    }
    return new Declarables(declarables
            .toArray(new Declarable[0]));
}

my.queues=foo,bar,baz
my.exchange=qux
my.routing.keys=rk1,rk2,rk3
...