Package org.axonframework.axonserver.connector.event

Class ConditionConverter

java.lang.Object
org.axonframework.axonserver.connector.event.ConditionConverter
@Internal public final class ConditionConverter extends Object
Utility class containing operations to convert Axon Framework's SourcingCondition and StreamingCondition into an Axon Server SourceEventsRequest and StreamEventsRequest respectively.
Since:
5.0.0
Author:
Steven van Beelen

  • Method Details

    • convertAppendCondition

      public static io.axoniq.axonserver.grpc.event.dcb.ConsistencyCondition convertAppendCondition(@Nonnull AppendCondition condition)
      Converts the given condition into a ConsistencyCondition.

      The AppendCondition.consistencyMarker()} translates to the consistency marker value. The EventsCondition.criteria() are flattened before being mapped to Criterion.

      Parameters:
      condition - The AppendCondition to base the ConsistencyCondition on.
      Returns:
      A ConsistencyCondition based on the given condition.

    • convertSourcingCondition

      public static io.axoniq.axonserver.grpc.event.dcb.SourceEventsRequest convertSourcingCondition(@Nonnull SourcingCondition condition)
      Converts the given condition into a SourceEventsRequest.

      The SourcingCondition.start() translates to the from sequence value. The EventsCondition.criteria() are flattened before being mapped to Criterion.

      Parameters:
      condition - The SourcingCondition to base the SourceEventsRequest on.
      Returns:
      A SourceEventsRequest based on the given condition.

    • convertStreamingCondition

      public static io.axoniq.axonserver.grpc.event.dcb.StreamEventsRequest convertStreamingCondition(@Nonnull StreamingCondition condition)
      Converts the given condition into a StreamEventsRequest.

      The StreamingCondition.position() translates to the from sequence value. The StreamingCondition.criteria() are flattened before being mapped to Criterion.

      Parameters:
      condition - The StreamingCondition to base the StreamEventsRequest on.
      Returns:
      A StreamEventsRequest based on the given condition.