Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
org.infinispan.stream.impl | |
org.infinispan.stream.impl.local |
Modifier and Type | Method and Description |
---|---|
CacheStream<R> |
CacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed
processing.
|
Modifier and Type | Interface and Description |
---|---|
interface |
QueueingSegmentListener<K,V,E extends Event<K,V>>
This interface describes methods needed for a segment listener that is used when iterating over the current
events and be able to queue them properly
|
Modifier and Type | Field and Description |
---|---|
protected CacheStream.SegmentCompletionListener |
AbstractCacheStream.segmentCompletionListener |
Modifier and Type | Method and Description |
---|---|
protected static CacheStream.SegmentCompletionListener |
DistributedCacheStream.composeWithExceptions(CacheStream.SegmentCompletionListener a,
CacheStream.SegmentCompletionListener b)
Given two SegmentCompletionListener, return a SegmentCompletionListener that
executes both in sequence, even if the first throws an exception, and if both
throw exceptions, add any exceptions thrown by the second as suppressed
exceptions of the first.
|
Modifier and Type | Method and Description |
---|---|
protected static CacheStream.SegmentCompletionListener |
DistributedCacheStream.composeWithExceptions(CacheStream.SegmentCompletionListener a,
CacheStream.SegmentCompletionListener b)
Given two SegmentCompletionListener, return a SegmentCompletionListener that
executes both in sequence, even if the first throws an exception, and if both
throw exceptions, add any exceptions thrown by the second as suppressed
exceptions of the first.
|
CacheStream<R> |
AbstractDelegatingCacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) |
CacheStream<R> |
DistributedCacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) |
Modifier and Type | Method and Description |
---|---|
CacheStream<R> |
LocalCacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) |
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.