hasql-queue
A PostgreSQL backed queue
https://github.com/jfischoff/hasql-queue#readme
| LTS Haskell 20.9: | 1.2.0.2 |
| Stackage Nightly 2023-01-31: | 1.2.0.2 |
| Latest on Hackage: | 1.2.0.2 |
Maintained by jonathangfischoff@gmail.com
This version can be pinned in stack with:
hasql-queue-1.2.0.2@sha256:a02aea32f1bc8361cfd9b69abdb201ee68689fb4e721426ee50a9a3af05d72e5,4531Module documentation for 1.2.0.2
- Hasql
Depends on 20 packages(full list with versions):
Used by 1 package in nightly-2023-01-31(full list with versions):
hasql-queue
This module utilizes PostgreSQL to implement a durable queue for efficently processing payloads.
Typically a producer would enqueue a new payload as part of larger database transaction
createAccount userRecord = transaction Serializable Write $ do
createUser userRecord
enqueue "queue_channel" emailEncoder [makeVerificationEmail userRecord]
In another thread or process the consumer would drain the queue.
-- Wait for a single new record and try to send the email 5 times for giving
-- up and marking the payload as failed.
forever $ withDequeue "queue_channel" conn emailDecoder 5 1 $
mapM_ sendEmail