Network.NSQ.Parser

Documentation

message :: Parser Message

Parse the low level message frames into a Message type.

decode :: ByteString -> Maybe Message

Decode the ByteString to an Message

encode :: Command -> ByteString

Encode a Command into raw ByteString to send to the network to the nsqd daemon. There are a few gotchas here; You can only have one Sub (topic/channel) per nsqld connection, any other will yield Invalid. Also you can publish to any number of topic without limitation.