| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
MessageDb.Subscription
Description
Subscribe to a category and react to the messages.
Synopsis
- data Subscription = Subscription {
- categoryName :: CategoryName
- messagesPerTick :: NumberOfMessages
- tickInterval :: Microseconds
- logMessages :: NonEmpty Message -> IO ()
- failureStrategy :: FailureStrategy
- positionStrategy :: PositionStrategy
- handlers :: SubscriptionHandlers
- consumerGroup :: Maybe ConsumerGroup
- condition :: Maybe Condition
- correlation :: Maybe Correlation
- subscribe :: CategoryName -> Subscription
- start :: WithConnection -> Subscription -> IO Void
Documentation
data Subscription Source #
Defines how to subscribe to a category.
Constructors
subscribe :: CategoryName -> Subscription Source #
Construct a new subscription.
start :: WithConnection -> Subscription -> IO Void Source #
Start the subscription. Notice this will never return.