amqp-utils 0.6.0.0 → 0.6.1.0
raw patch · 4 files changed
+33/−8 lines, 4 files
Files
- ChangeLog.md +4/−0
- Network/AMQP/Utils/Helpers.hs +16/−7
- README.md +12/−0
- amqp-utils.cabal +1/−1
ChangeLog.md view
@@ -1,5 +1,9 @@ # Revision history for haskell-amqp-utils +## 0.6.1.0 -- 2020-03-11++* add remaining message properties as callback environment variables, too+ ## 0.6.0.0 -- 2020-03-10 * update and amend README
Network/AMQP/Utils/Helpers.hs view
@@ -199,6 +199,15 @@ , ("TIMESTAMP", timestamp) , ("PRIORITY", pri) , ("REDELIVERED", redeliv)+ , ("SIZE", size)+ , ("TYPE", mtype)+ , ("USERID", muserid)+ , ("APPID", mappid)+ , ("CLUSTERID", mclusterid)+ , ("REPLYTO", mreplyto)+ , ("CORRID", mcorrid)+ , ("EXPIRATION", mexp)+ , ("DELIVERYMODE", mdelivmode) ] ++ headersEnv return (cmdline, environment)@@ -236,13 +245,13 @@ rkey = Just . T.unpack $ envRoutingKey envi messageid = fmap T.unpack $ msgID msg pri = fmap show $ msgPriority msg- mtype = fmap show $ msgType msg- muserid = fmap show $ msgUserID msg- mappid = fmap show $ msgApplicationID msg- mclusterid = fmap show $ msgClusterID msg- mreplyto = fmap show $ msgReplyTo msg- mcorrid = fmap show $ msgCorrelationID msg- mexp = fmap show $ msgExpiration msg+ mtype = fmap T.unpack $ msgType msg+ muserid = fmap T.unpack $ msgUserID msg+ mappid = fmap T.unpack $ msgApplicationID msg+ mclusterid = fmap T.unpack $ msgClusterID msg+ mreplyto = fmap T.unpack $ msgReplyTo msg+ mcorrid = fmap T.unpack $ msgCorrelationID msg+ mexp = fmap T.unpack $ msgExpiration msg mdelivmode = fmap show $ msgDeliveryMode msg size = Just . show $ BL.length body redeliv =
README.md view
@@ -247,6 +247,18 @@ AMQP_PRIORITY AMQP_REDELIVERED +And the remaining message properties, too:++ AMQP_SIZE+ AMQP_TYPE+ AMQP_USERID+ AMQP_APPID+ AMQP_CLUSTERID+ AMQP_REPLYTO+ AMQP_CORRID+ AMQP_EXPIRATION+ AMQP_DELIVERYMODE+ Message headers, if any, are available as AMQP_HEADER_KEY_0
amqp-utils.cabal view
@@ -1,6 +1,6 @@ name: amqp-utils -version: 0.6.0.0+version: 0.6.1.0 synopsis: AMQP toolset for the command line