-{-# LANGUAGE OverloadedStrings #-}
+-- generic AMQP publisher
import Control.Concurrent (threadDelay)
import qualified Control.Exception as X
-{-# LANGUAGE OverloadedStrings #-}
-
-- generic amqp consumer
---
--- compile:
--- ghc -O2 -threaded --make konsum.hs
---
--- run:
--- ./konsum
--- ./konsum -o amqp.example.com -p 5673 -T -k amqp-key.pem -c amqp-crt.pem -y vhost -x exchange -X./callback.sh -a -c -a callback.config.sh -f 2 -r routing.key.# -l 500
--- ./konsum -o amqp.example.com -U user -P pass -q queue -t
---
--- custom CA cert via enviroment:
--- $ env SYSTEM_CERTIFICATE_PATH=/etc/amqp/cacert.crt ./konsum -T -y vhost -x exchange
---
--- Stop with ^C
import Control.Concurrent
import qualified Control.Exception as X