LineBuffering

[fd/haskell-amqp-utils.git] / agitprop.hs

diff --git a/agitprop.hs b/agitprop.hs
index 0b6399dd85ccb33cd049233d9b707a986eb1a7ca..96669e181add1970ecba44b3b53f6adeeb4ce915 100644 (file)
--- a/agitprop.hs
+++ b/agitprop.hs
@@ -33,12 +33,15 @@ import           System.FilePath.Posix.ByteString
 import           System.INotify
 #endif
 import qualified System.Posix.Files.ByteString    as F
+import           System.IO
 
 main :: IO ()
 main = do
   hr "starting"
   tid <- myThreadId
   args <- getArgs >>= parseargs 'a'
+  hSetBuffering stdout LineBuffering
+  hSetBuffering stderr LineBuffering
   printparam "client version" ["amqp-utils", showVersion version]
   printparam "routing key" $ rKey args
   printparam "exchange" $ currentExchange args