Documentation

Fields

• categoryName :: Category

  Name of the Category to subscribe to.

• batchSize :: NumberOfMessages

  Max amount of messages to query for at once. Defaults to 100.

• tickInterval :: Microseconds

  Amount of time in Microseconds to sleep in between polls. Defaults to 100_000.

• logMessages :: NonEmpty Message -> IO ()

  Log messages when found. Defaults to '_ -> pure ()'.

• failureStrategy :: FailureStrategy

  Strategy for dealing with failures. Defaults to ignoreFailures.

• positionStrategy :: PositionStrategy

  Strategy for (re)storing subscription position. Defaults to dontSave.

• handlers :: SubscriptionHandlers

  Set of functions for handling different message types. Defaults to emptyHandlers.

• consumerGroup :: Maybe ConsumerGroup

  Set the consumer group information for parallel consumption. Defaults to Nothing.

• condition :: Maybe Condition

  SQL condition to filter the batch by. Defaults to Nothing.

• correlation :: Maybe Correlation

  Category or stream name recorded in message metadata's correlationStreamName attribute to filter the batch by. Defaults to Nothing.