Commit 431dfc2
Revise implementation of RedisMessageListenerContainer.
RedisMessageListenerContainer is now reimplemented using non-blocking synchronization guards and a state management to simplify its maintenances. Additionally, listener registration and subscription setup through the start() method awaits until the listener subscription is confirmed by the Redis server. The synchronization removes potential race conditions that could happen by concurrent access to blocking Redis connectors in which the registration state was guessed and not awaited.
Resolves: #964
Original Pull Request: #22561 parent 1c3a241 commit 431dfc2
File tree
10 files changed
+1132
-543
lines changed- src
- main
- asciidoc/reference
- java/org/springframework/data/redis/listener
- test/java/org/springframework/data/redis
- core
- listener
10 files changed
+1132
-543
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
50 | | - | |
| 50 | + | |
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
| |||
0 commit comments