Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-9721

Add non blocking Publisher for a Cache

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Major Major
    • 10.1.0.Final
    • None
    • Core, Publisher
    • None
    • DataGrid Sprint #29

      We currently have distributed streams. Unfortunately this requires blocking to operate at various levels. We need to instead expose some sort of distributed publisher that allows for distributed operations but in a totally non blocking way.

      I had started a branch that has some ideas for the public API https://github.com/wburns/infinispan/tree/ISPN-9565_publisher. I believe the use of the various compose methods should help reduce complexity as all of the operations can be in a utility class if needed.

          1.
          		 Implement single response publisher methods Sub-task Closed Major Will Burns
          2.
          		 Implement streaming response publisher method Sub-task Closed Major Ryan Emerson
          3.
          		 Convert DistributedStreams to use Distributed Publisher for single response Sub-task Closed Major Will Burns
          4.
          		 Convert DistributedStreams to use Distributed Publisher for streaming response Sub-task Closed Major Will Burns
          5.
          		 Expose Cache based Publisher Sub-task Closed Major Will Burns
          6.
          		 Handle non segmented container/store for publisher more efficiently Sub-task Closed Major Will Burns
          7.
          		 Add partition handling for PublisherManager Sub-task Closed Major Unassigned
          8.
          		 Address review comments for ISPN-9811 Sub-task Closed Major Unassigned
          9.
          		 Convert Primitive Cache Streams to use Distributed Publisher underneath Sub-task Closed Major Will Burns
          10.
          		 LocalPublisherManagerImpl performs blocking Cache operations Sub-task Closed Major Will Burns
          11.
          		 Remove old DistributedStreams iterator and reduction based code Sub-task Closed Major Will Burns

              wburns@redhat.com Will Burns
              wburns@redhat.com Will Burns
              Archiver:
              rhn-support-adongare Amol Dongare

                Created:
                Updated:
                Resolved:
                Archived: