jjzjj

RedisQueueMessageDrivenEndpoint

全部标签

java - 在 Spring Integration 中为 Redis 创建 MessageSource

我想配置InboundChannelAdapter以便它应该从redis队列中弹出消息并将其传递给基于Java的注释中的ServiceActivator(只是,更喜欢避免XML)。我从Spring文档中找到了代码:@Bean("someAdapter.source")@EndpointId("someAdapter")@InboundChannelAdapter(channel="channel3",poller=@Poller(fixedDelay="5000"))publicMessageSourcesource(){return()->{...};}但我在这里不明白的是,如何使用

java - 在 Spring Integration 中为 Redis 创建 MessageSource

我想配置InboundChannelAdapter以便它应该从redis队列中弹出消息并将其传递给基于Java的注释中的ServiceActivator(只是,更喜欢避免XML)。我从Spring文档中找到了代码:@Bean("someAdapter.source")@EndpointId("someAdapter")@InboundChannelAdapter(channel="channel3",poller=@Poller(fixedDelay="5000"))publicMessageSourcesource(){return()->{...};}但我在这里不明白的是,如何使用