MultiStreamableMessageSource.Builder
. This class
belongs in the messaging
module instead of the eventsourcing
module.@Deprecated public static class MultiStreamableMessageSource.Builder extends MultiStreamableMessageSource.Builder
MultiStreamableMessageSource
. The configurable filed
trackedEventComparator
, which decides which message to process first if there is a choice defaults to the
oldest message available (using the event's timestamp). The stream on which long polling is done for
MultiSourceBlockingStream#hasNextAvailable(int, TimeUnit)
is also configurable.
Constructor and Description |
---|
Builder()
Deprecated.
|
addMessageSource, build, longPollingSource, trackedEventComparator
Copyright © 2010–2023. All rights reserved.