Uploaded image for project: 'Spring Data Redis'
  1. Spring Data Redis
  2. DATAREDIS-612

Provide reactive RedisMessageListenerContainer

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Complete
    • Affects Version/s: None
    • Fix Version/s: 2.1 M3 (Lovelace)
    • Component/s: Core
    • Labels:
      None

      Description

      Provide a reactive implementation of a RedisMessageListenerContainer to subscribe/unsubscribe channels and patterns.

      Something like:

      class ReactiveMessageReceiver {
      
        // …
      
        Flux<ChannelMessage> receive(Topic topic);
      
        Flux<PatternMessage> receive(PatternTopic topic);
      
        // …
      }
      
      ReactiveMessageReceiver receiver = …;
      
      receiver.receive(ChannelTopic.of("my-channel")).subscribe(message -> …);
      

        Attachments

          Activity

            People

            • Assignee:
              mp911de Mark Paluch
              Reporter:
              mp911de Mark Paluch
              Last updater:
              Christoph Strobl
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: