zeromq3-haskell-0.2: examples/perf/remote_thr.hs

import Control.Monad
import Control.Concurrent
import System.IO
import System.Exit
import System.Environment
import qualified System.ZMQ3 as ZMQ
import qualified Data.ByteString as SB

main :: IO ()
main = do
    args <- getArgs
    when (length args /= 3) $ do
        hPutStrLn stderr usage
        exitFailure
    let connTo  = args !! 0
        size    = read $ args !! 1
        count   = read $ args !! 2
        message = SB.replicate size 0x65
    ZMQ.withContext $ \c ->
        ZMQ.withSocket c ZMQ.Pub $ \s -> do
            ZMQ.connect s connTo
            replicateM_ count $ ZMQ.send s [] message
            threadDelay 10000000

usage :: String
usage = "usage: remote_thr <connect-to> <message-size> <message-count>"