PollerMetadata имеет значение null, когда мы используем настраиваемые pollerMetadata в @InboundChannelAdapter

Я реализую собственный источник сообщений для извлечения данных. И когда я запускаю свой компонент приложения PollerMetadata, он не успевает инициализироваться до @InboundChannelAdapter и выдает исключение:

Caused by: java.lang.IllegalArgumentException: No poller has been defined for channel-adapter 'statusFlow.org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean#0', and no default poller is available within the context.

Мой код:

@Bean("myTrigger")
public PeriodicTrigger periodicTrigger() {
    PeriodicTrigger trigger = new PeriodicTrigger(2000);
    trigger.setFixedRate(true);
    return trigger;
}

@Bean("myPollerMetadata")
public PollerMetadata currentRackStatusLandingFlowPollerMetadata(@Qualifier("myTrigger") PeriodicTrigger trigger) {
    PollerMetadata metadata = new PollerMetadata();
    metadata.setTrigger(trigger);
    metadata.setMaxMessagesPerPoll(1);
    return metadata;
}

@InboundChannelAdapter(poller = @Poller(value = "myPollerMetadata"))
public MessageSource<List<Status>> statusSource() {
    return () -> new DefaultMessageBuilderFactory()
            .withPayload(statusService.getCurrentStatuses())
            .build();
}

Мой вопрос:

Как настроить PollerMetadata для @InboundChannelAdapter?

Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Версия Java на основе версии загрузки
Версия Java на основе версии загрузки
Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.
Документирование API с помощью Swagger на Springboot
Документирование API с помощью Swagger на Springboot
В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .
0
0
300
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Согласно вашему исключению, история не об этом @InboundChannelAdapter, а что-то вроде IntegrationFlows.from(statusSource()).

В этом случае вам необходимо настроить опрашивающее устройство для определения DSL:

@Bean
IntegrationFlow yourFlow(PollerMetadata myPollerMetadata) {
    return IntegrationFlows.from(statusSource(), e -> e.poller(myPollerMetadata))

Аннотация @InboundChannelAdapter не имеет смысла для определения Java DSL и IntegrationFlow.

Другие вопросы по теме