Package | Description |
---|---|
org.axonframework.axonserver.connector.event.axon | |
org.axonframework.common.stream | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
Modifier and Type | Class and Description |
---|---|
class |
EventBuffer
Client-side buffer of messages received from the server.
|
Modifier and Type | Method and Description |
---|---|
static <M> Stream<M> |
StreamUtils.asStream(BlockingStream<M> messageStream)
Convert the given
messageStream to a regular java Stream . |
Modifier and Type | Interface and Description |
---|---|
interface |
TrackingEventStream
Describes a stream of
TrackedEventMessages . |
Modifier and Type | Method and Description |
---|---|
BlockingStream<M> |
StreamableMessageSource.openStream(TrackingToken trackingToken)
Open a stream containing all messages since given tracking token.
|
Copyright © 2010–2023. All rights reserved.