Как настроить адаптер входящего канала Redis в Spring интеграции DSL? - PullRequest
Новая
       34

Как настроить адаптер входящего канала Redis в Spring интеграции DSL?

1 голос
/ 31 мая 2019

Я пытаюсь настроить службу кэширования, используя загрузку / интеграцию Spring.Эта служба должна получать данные из базы данных Redis каждые 6 минут.Я следовал этой документации , и нет примера для интеграции DSL Spring.

<int-redis:inbound-channel-adapter id="redisAdapter"
   topics="thing1, thing2"
   channel="receiveChannel"
   error-channel="testErrorChannel"
   message-converter="testConverter" />

Я также следовал примеру, упомянутому на этой странице StackOverflow .

@Bean
RedisQueueMessageDrivenEndpoint redisQueueMessageDrivenEndpoint(RedisConnectionFactory redisConnectionFactory, RedisSerializer<?> serializer) {
    RedisQueueMessageDrivenEndpoint endpoint =
                new RedisQueueMessageDrivenEndpoint("archive.post.publication.queue", redisConnectionFactory);
    endpoint.setOutputChannelName("postPublicationChannel");
    endpoint.setErrorChannelName("postPublicationLoggingChannel");
    endpoint.setReceiveTimeout(5000);
    endpoint.setSerializer(serializer);
    return endpoint;
}

Я пробовал примеры из различной документации, и ни один из них не имел отношения к моему сценарию.Любая помощь высоко ценится?

...