Skip to content

Commit 81f8966

Browse files
committed
Fix documentation for MessageListenerAdapter Java config.
Closes #2524
1 parent 7e1746c commit 81f8966

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/main/asciidoc/reference/redis-messaging.adoc

+7-2
Original file line numberDiff line numberDiff line change
@@ -99,11 +99,16 @@ class MyConfig {
9999
}
100100
101101
@Bean
102-
RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, DefaultMessageDelegate listener) {
102+
MessageListenerAdapter messageListenerAdapter(DefaultMessageDelegate listener) {
103+
return new MessageListenerAdapter(listener, "handleMessage");
104+
}
105+
106+
@Bean
107+
RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, MessageListenerAdapter listener) {
103108
104109
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
105110
container.setConnectionFactory(connectionFactory);
106-
container.addMessageListener(new MessageListenerAdapter(listener, "handleMessage"), ChannelTopic.of("chatroom"));
111+
container.addMessageListener(listener, ChannelTopic.of("chatroom"));
107112
return container;
108113
}
109114
}

0 commit comments

Comments
 (0)