Package com.eventstore.dbclient

Class SubscriptionFilterBuilder

java.lang.Object
com.eventstore.dbclient.SubscriptionFilterBuilder
public class SubscriptionFilterBuilder extends Object
Utility class for building a subscription filter.

  • Method Details

    • withMaxWindow

      public SubscriptionFilterBuilder withMaxWindow(int maxWindow)
      The maximum number of events that are filtered out before the page is returned. Must be greater than 0, if supplied.

    • withStreamNameRegularExpression

      public SubscriptionFilterBuilder withStreamNameRegularExpression(@NotNull @NotNull String pattern)
      A regex to filter events based on their stream name.

    • addStreamNamePrefix

      public SubscriptionFilterBuilder addStreamNamePrefix(@NotNull @NotNull String prefix)
      A string prefix to filter events based on their stream name.

    • withEventTypeRegularExpression

      public SubscriptionFilterBuilder withEventTypeRegularExpression(@NotNull @NotNull String pattern)
      A regex to filter events based on their type.

    • addEventTypePrefix

      public SubscriptionFilterBuilder addEventTypePrefix(@NotNull @NotNull String prefix)
      A string prefix to filter events based on their type.

    • withCheckpointer

      public SubscriptionFilterBuilder withCheckpointer(@NotNull @NotNull Checkpointer checkpointer, int intervalMultiplierUnsigned)
      Calls a callback everytime a checkpoint is reached.
      Parameters:
      checkpointer - a callback.
      intervalMultiplierUnsigned - defines how often this callback is called.

    • withCheckpointer

      public SubscriptionFilterBuilder withCheckpointer(@NotNull @NotNull Checkpointer checkpointer)
      Calls a callback everytime a checkpoint is reached.
      Parameters:
      checkpointer - a callback.

    • build

      public SubscriptionFilter build()
      Returns a configured subscription filter.
      Returns: