snd_rcv.hs

-- rcv.hs

import System.ZMQ as ZMQ
import Control.Monad

main = do context <- ZMQ.init 1
          sock <- socket context Sub
          subscribe sock ""
          connect sock "tcp://localhost:5555"
          forever $ do
            str <- receive sock []
            print str


-- snd.hs

import System.ZMQ as ZMQ
import Control.Monad
import Data.ByteString.Lazy hiding (map)
import Data.ByteString.Internal

main = do context <- ZMQ.init 1
          sock <- socket context Pub
          bind sock "tcp://127.0.0.1:5555"
          -- 99% sure there's a better way to do this
          forever $ send' sock (pack $ map c2w "Foo") []