Hasql.Queue.Low.AtMostOnce

Documentation

enqueue

Arguments

:: Text

Notification channel name. Any valid PostgreSQL identifier

-> Connection

Connection

-> Value a

Payload encoder

-> [a]

List of payloads to enqueue

-> IO ()

Enqueue a payload.

dequeue

Arguments

:: Text

Notification channel name. Any valid PostgreSQL identifier

-> Connection

Connection

-> Value a

Payload decoder

-> Int

Element count

-> IO [a]

Dequeue a list of payloads.