Documentation

a parsed message from the queue

send a message to a queue. Enforces that the message type and queue name are correct at the type level

let newUsers = key "users" & word "new" :: Key Route User
publish conn newUsers (User "username")

Publishing to a Binding Key results in an error

-- Compiler error! This doesn't make sense
let users = key "users" & many :: Key Binding User
publish conn users (User "username")

publish a message to a routing key, without making sure a queue exists to handle it

publishToExchange conn key (User "username")

Wait until a message is read from the queue. Throws an exception if the incoming message doesn't match the key type

m <- Worker.takeMessage conn queue
print (value m)

Create a worker which loops and handles messages. Throws an exception if the incoming message doesn't match the key type. It is recommended that you catch errors in your handler and allow message parsing errors to crash your program.

Worker.worker conn queue $ \m -> do
  print (value m)

Block while checking for messages every N microseconds. Return once you find one.

res <- consumeNext conn queue
case res of
  (Parsed m) -> print m
  (Error e) -> putStrLn "could not parse message"

Check for a message once and attempt to parse it

res <- consume conn queue
case res of
  Just (Parsed m) -> print m
  Just (Error e) -> putStrLn "could not parse message"
  Nothing -> putStrLn "No messages on the queue"