Disque client for Haskell

Disque is a distributed, in memory, message broker.

NOTE: most of the functionality in this package relies on running a disque-server process

Quick Start

The example script is setup to run on invocation:

./example.hs

To build the project, simply run:

stack build

Example

Integrate disque.hs into your code:

{-# LANGUAGE OverloadedStrings #-}

import Control.Monad.IO.Class
import Database.Disque

main :: IO ()
main = do
  conn <- connect disqueConnectInfo
  runDisque conn $ do
    let timeout = 0
    addjob "test_queue" "test data" timeout >>= liftIO . print
    getjob ["test_queue"] >>= liftIO . print

Some commands are not implemented in the test command-line client.

Command-line client

This project contains a minimal Run the command line client to get a feel for Disque:

stack build
stack exec disque.hs