Package org.axonframework.messaging.eventstreaming

Interface MultiStreamableEventSource.SourceCollector

Enclosing class:
MultiStreamableEventSource
public static interface MultiStreamableEventSource.SourceCollector
Intermediate builder for collecting event sources before creating a MultiStreamableEventSource. Allows adding multiple sources and provides terminal operations for creating the final instance.

  • Method Details

    • and

      MultiStreamableEventSource.SourceCollector and(String sourceName, StreamableEventSource source)
      Adds another event source to the collection.
      Parameters:
      sourceName - A unique name identifying the source.
      source - The event source to add.
      Returns:
      This SourceCollector for fluent chaining.
      Throws:
      IllegalArgumentException - if the sourceName is already used.

    • comparingTimestamps

      MultiStreamableEventSource comparingTimestamps()
      Creates a MultiStreamableEventSource using timestamp-based comparison (oldest event first). This is the default behavior, comparing events based on their timestamp.
      Returns:
      A configured MultiStreamableEventSource instance.

    • comparingUsing

      MultiStreamableEventSource comparingUsing(Comparator<MessageStream.Entry<EventMessage>> comparator)
      Creates a MultiStreamableEventSource using a custom comparator.
      Parameters:
      comparator - The comparator to use when deciding which message to process first. A result of <= 0 means the message from the first stream is consumed first.
      Returns:
      A configured MultiStreamableEventSource instance.