MultiStreamableMessageSource
. This class belongs in
the messaging
module instead of the eventsourcing
module.@Deprecated public class MultiStreamableMessageSource extends MultiStreamableMessageSource
MultiSourceBlockingStream#hasNextAvailable()
except for the last stream configured by the
MultiStreamableMessageSource.Builder.addMessageSource(String, StreamableMessageSource)
or by explicit
configuration using MultiStreamableMessageSource.Builder.longPollingSource(String)
. This stream long polls
for a fraction of the specified duration before looping through the sources again repeating until the duration has
been met. This ensures the highest chance of a consumable message being found.Modifier and Type | Class and Description |
---|---|
static class |
MultiStreamableMessageSource.Builder
Deprecated.
In favor of
MultiStreamableMessageSource.Builder . This class
belongs in the messaging module instead of the eventsourcing module. |
Modifier | Constructor and Description |
---|---|
protected |
MultiStreamableMessageSource(MultiStreamableMessageSource.Builder builder)
Deprecated.
In favor of
MultiStreamableMessageSource(org.axonframework.eventhandling.MultiStreamableMessageSource.Builder) .
This class belongs in the messaging module instead of the eventsourcing module. |
Modifier and Type | Method and Description |
---|---|
static MultiStreamableMessageSource.Builder |
builder()
Deprecated.
In favor of
MultiStreamableMessageSource.builder() . This
class belongs in the messaging module instead of the eventsourcing module. |
createHeadToken, createTailToken, createTokenAt, createTokenSince, openStream
@Deprecated protected MultiStreamableMessageSource(MultiStreamableMessageSource.Builder builder)
MultiStreamableMessageSource(org.axonframework.eventhandling.MultiStreamableMessageSource.Builder)
.
This class belongs in the messaging
module instead of the eventsourcing
module.MultiStreamableMessageSource
based on the fields contained in the
MultiStreamableMessageSource.Builder
.
builder
- the MultiStreamableMessageSource.Builder
used to instantiate a
MultiStreamableMessageSource
instance.@Deprecated public static MultiStreamableMessageSource.Builder builder()
MultiStreamableMessageSource.builder()
. This
class belongs in the messaging
module instead of the eventsourcing
module.MultiStreamableMessageSource
. The configurable field
trackedEventComparator
, which decides which message to process first if there is a choice defaults to the
oldest message available (using the event's timestamp).MultiStreamableMessageSource
.Copyright © 2010–2023. All rights reserved.