postgresql-simple-queue 0.5.0.1 → 0.5.1.0

raw patch · 3 files changed

+4/−4 lines, 3 files

Files

• README.md +1/−1
• postgresql-simple-queue.cabal +1/−1
• src/Database/PostgreSQL/Simple/Queue.hs +2/−2

@@ -1,6 +1,6 @@ # postgresql-simple-queue -This module utilize PostgreSQL to implement a durable queue for efficently processing arbitrary payloads which can be represented as JSON.+This module utilizes PostgreSQL to implement a durable queue for efficently processing arbitrary payloads which can be represented as JSON.  Typically a producer would enqueue a new payload as part of larger database transaction 

@@ -1,5 +1,5 @@ name:                postgresql-simple-queue-version:             0.5.0.1+version:             0.5.1.0 synopsis: A PostgreSQL backed queue description:  This module utilize PostgreSQL to implement a durable queue for efficently processing arbitrary payloads which can be represented as JSON.

@@ -264,12 +264,12 @@     shutdown. For a DB API version see 'unlockDB' -} unlock :: String -> Connection -> PayloadId -> IO ()-unlock schemaName conn x = runDBTSerializable (unlockDB schemaName x) conn+unlock schemaName conn x = runDBT  (unlockDB schemaName x) ReadCommitted conn  -- | Transition a 'Payload' to the 'Dequeued' state. his functions runs --   'dequeueDB' as a 'Serializable' transaction. dequeue :: String -> Connection -> PayloadId -> IO ()-dequeue schemaName conn x = runDBTSerializable (dequeueDB schemaName x) conn+dequeue schemaName conn x = runDBT (dequeueDB schemaName x) ReadCommitted conn  {-| Get the number of rows in the 'Enqueued' state. This function runs     'getCountDB' in a 'ReadCommitted' transaction.