From 81f896693fda91b563ec33f4fdead43e5ca4470d Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Tue, 14 Mar 2023 08:55:24 +0100 Subject: [PATCH] Fix documentation for MessageListenerAdapter Java config. Closes #2524 --- src/main/asciidoc/reference/redis-messaging.adoc | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/asciidoc/reference/redis-messaging.adoc b/src/main/asciidoc/reference/redis-messaging.adoc index 561096c2f..6dc2a26c0 100644 --- a/src/main/asciidoc/reference/redis-messaging.adoc +++ b/src/main/asciidoc/reference/redis-messaging.adoc @@ -99,11 +99,16 @@ class MyConfig { } @Bean - RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, DefaultMessageDelegate listener) { + MessageListenerAdapter messageListenerAdapter(DefaultMessageDelegate listener) { + return new MessageListenerAdapter(listener, "handleMessage"); + } + + @Bean + RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, MessageListenerAdapter listener) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); - container.addMessageListener(new MessageListenerAdapter(listener, "handleMessage"), ChannelTopic.of("chatroom")); + container.addMessageListener(listener, ChannelTopic.of("chatroom")); return container; } }