amqp-utils 0.3.2.0 → 0.3.2.1

raw patch · 4 files changed

+10/−23 lines, 4 files

Files

• README.md +1/−1
• agitprop.hs +1/−1
• amqp-utils.cabal +8/−6
• konsum.hs +0/−15

@@ -33,7 +33,7 @@       -s INT         --heartbeats=INT                 heartbeat interval (0=disable, default: set by server)       -n NAME        --name=NAME                      connection name, will be shown in RabbitMQ web interface -## examples+### examples  connect to localhost with default credentials and attach to a new temp queue on exchange "default":

@@ -1,4 +1,4 @@-{-# LANGUAGE OverloadedStrings #-}+-- generic AMQP publisher  import Control.Concurrent (threadDelay) import qualified Control.Exception as X

@@ -1,15 +1,17 @@ name:                amqp-utils -version:             0.3.2.0+version:             0.3.2.1  synopsis:            Generic Haskell AMQP Consumer  description:         AMQP consumer which can-  - create a temporary queue and attach it to an exchange, or-  - attach to an existing queue;-  - display header and body info;-  - save message bodies to files;-  - call a callback script+  create a temporary queue and attach it to an exchange, or+  attach to an existing queue;+  display header and body info;+  save message bodies to files;+  call a callback script.+  AMQP publisher with file, line-by-line and+  hotfolder capabilities.  license:             GPL-3 

@@ -1,19 +1,4 @@-{-# 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