Uses of Interface
io.axoniq.axonserver.connector.event.PersistentStreamSegment
-
Packages that use PersistentStreamSegment Package Description io.axoniq.axonserver.connector.event io.axoniq.axonserver.connector.event.impl -
-
Uses of PersistentStreamSegment in io.axoniq.axonserver.connector.event
Methods in io.axoniq.axonserver.connector.event that return types with arguments of type PersistentStreamSegment Modifier and Type Method Description Consumer<PersistentStreamSegment>PersistentStreamCallbacks. onAvailable()Returns the callback that the connector invokes when an event is available on a persistent stream segment.Consumer<PersistentStreamSegment>PersistentStreamCallbacks. onSegmentClosed()Returns the callback that the connector invokes when a persistent stream segment is closed.Consumer<PersistentStreamSegment>PersistentStreamCallbacks. onSegmentOpened()Returns the callback that the connector invokes when a persistent stream segment is opened.Constructor parameters in io.axoniq.axonserver.connector.event with type arguments of type PersistentStreamSegment Constructor Description PersistentStreamCallbacks(Consumer<PersistentStreamSegment> onSegmentOpened, Consumer<PersistentStreamSegment> onSegmentClosed, Consumer<PersistentStreamSegment> onAvailable, Consumer<Throwable> onClosed)Instantiates the callbacks object. -
Uses of PersistentStreamSegment in io.axoniq.axonserver.connector.event.impl
Classes in io.axoniq.axonserver.connector.event.impl that implement PersistentStreamSegment Modifier and Type Class Description classBufferedPersistentStreamSegmentImplementation of thePersistentStreamSegment.
-