Safe Haskell	None
Language	Haskell2010

Client

Contents

Synopsis

Documentation

Client is used to iteract with the NATS server.

newClient creates a new Client instance and starts the necessary pipelines.

defaultConn is a sane default connection that can be used as an argument to newClient.

MsgView represents a MSG in the NATS protocol.

Constructors

MsgView
Fields subject :: ByteString The subject of the message. sid :: ByteString The SID (subscription ID) of the message. replyTo :: Maybe ByteString The replyTo subject, if any. payload :: Maybe ByteString The payload of the message, if any. headers :: Maybe [(ByteString, ByteString)] Headers associated with the message, if any.

Instances details

Show MsgView #
Instance details Defined in Client Methods showsPrec :: Int -> MsgView -> ShowS # show :: MsgView -> String # showList :: [MsgView] -> ShowS #
Eq MsgView #
Instance details Defined in Client Methods (==) :: MsgView -> MsgView -> Bool # (/=) :: MsgView -> MsgView -> Bool #

publish :: Client -> Subject -> [PubOptions -> PubOptions] -> IO () #

publish sends a message to the NATS server.

subscribe :: Client -> Subject -> (MsgView -> IO ()) -> IO SID #

subscribe is used to subscribe to a subject on the NATS server.

unsubscribe is used to unsubscribe from a subject on the NATS server.

ping :: Client -> IO () -> IO () #

ping is used to send a ping message to the NATS server.

pubWithPayload :: Payload -> PubOptions -> PubOptions #

pubWithPayload is used to set the payload for a publish operation.

pubWithReplyCallback :: (MsgView -> IO ()) -> PubOptions -> PubOptions #

pubWithReplyCallback is used to set a callback for a reply to a publish operation.

pubWithHeaders :: Headers -> PubOptions -> PubOptions #

pubWithHeaders is used to set headers for a publish operation.

Orphan instances

SelfHealer ByteString ParserErr #
Instance details Methods heal :: ByteString -> ParserErr -> (ByteString, ParserState)