Как параметризовать объект в потоке интеграции?

У меня есть поток интеграции для опроса данных из базы данных. Я установил источник сообщения, который возвращает список объектов, этот список я хочу передать методу handle в subFlow.

Это код для этих целей, но я получаю сообщение об ошибке компиляции: несовместимые типы Сообщение в список.

@Bean
    public IntegrationFlow integrationFlow(
            DataSource dataSource,
            MessageHandler amqpHandler,
            PersonService personService,
            PersonChecker personChecker) {
        return IntegrationFlows
                .from(getMessageSource(personService::getPersons), e -> e.poller(getPollerSpec()))
                .wireTap(subFlow -> subFlow.handle(personChecker::checkPerson))
                .split()
                .publishSubscribeChannel(pubSub -> pubSub
                        .subscribe(flow -> flow.bridge()
                                .transform(Transformers.toJson())
                                .handle(amqpHandler))
                        .subscribe(flow -> flow.bridge()
                                .handle(personService::markAsSent)))
                .get();
    }

Я знаю о решении передать службу и название метода handle(personChecker, checkPerson), но он мне не подходит.

Есть ли возможность передать wireTap подпоток в метод handle list с объектами Person вместо сообщения Message?