amqp-utils 0.6.1.0 → 0.6.1.1

raw patch · 4 files changed

+19/−3 lines, 4 files

Files

• ChangeLog.md +4/−0
• README.md +2/−1
• agitprop.hs +10/−0
• amqp-utils.cabal +3/−2

@@ -1,5 +1,9 @@ # Revision history for haskell-amqp-utils +## 0.6.1.1  -- 2021-05-11++* disable inotify on non-linux+ ## 0.6.1.0  -- 2020-03-11  * add remaining message properties as callback environment variables, too

@@ -268,8 +268,9 @@  etc. -## get the source!+## get it!  - git://woffs.de/git/fd/haskell-amqp-utils.git - https://woffs.de/git/fd/haskell-amqp-utils.git - https://git.sr.ht/~woffs/haskell-amqp-utils+- https://repology.org/project/haskell:amqp-utils/packages

@@ -5,10 +5,12 @@ import           Control.Concurrent import qualified Control.Exception             as X import qualified Data.ByteString.Lazy.Char8    as BL+#if linux_HOST_OS #if MIN_VERSION_hinotify(0,3,10) import qualified Data.ByteString.Char8         as BS #endif import           Data.List                     (isSuffixOf)+#endif import           Data.Maybe import qualified Data.Text                     as T import           Data.Time@@ -25,7 +27,9 @@ import           System.Directory import           System.Environment import           System.Exit+#if linux_HOST_OS import           System.INotify+#endif import qualified System.Posix.Files            as F  main :: IO ()@@ -64,6 +68,7 @@   X.catch     (if isDir        then do+#if linux_HOST_OS          setCurrentDirectory (inputFile args)          if (initialScan args)            then getDirectoryContents "." >>=@@ -80,6 +85,9 @@          sleepingBeauty >>= printparam "exception"          removeWatch wd          hr $ "END watching " ++ (inputFile args)+#else+         X.throw (X.ErrorCall "ERROR: watching a directory is only supported in Linux")+#endif        else do          hr $ "BEGIN sending"          messageFile <-@@ -117,6 +125,7 @@     , show ackType     ] +#if linux_HOST_OS -- | Hotfolder event handler handleEvent ::      (Maybe String -> BL.ByteString -> IO ()) -> [String] -> Event -> IO ()@@ -146,6 +155,7 @@   X.catch     (BL.readFile fileName >>= func (Just fileName))     (\e -> printparam "exception in handleFile" (e :: X.IOException))+#endif  -- | Publish one message with our settings publishOneMsg' :: Channel -> Args -> Maybe FilePath -> BL.ByteString -> IO ()

@@ -1,6 +1,6 @@ name:                amqp-utils -version:             0.6.1.0+version:             0.6.1.1  synopsis:            AMQP toolset for the command line @@ -76,8 +76,9 @@                        tls >= 1.3.9,                        amqp >=0.19,                        unix >= 2.7,-                       hinotify >= 0.3.8,                        magic+  if os(linux)+    build-depends:     hinotify >= 0.3.8    ghc-options:         -threaded -Wall