Portability | non-portable |
---|---|
Stability | experimental |
Safe Haskell | None |
Publish side of 'Publish/Subscribe'
Publisher
Forwarder
withForwarder :: Context -> Service -> [Service] -> (String, LinkType) -> (String, LinkType) -> OnError_ -> Control a -> IO aSource
A simple forwarder, i.e. a device that connects to a publisher and provides an additional endpoint for more subscribers to connect to. A forwarder, hence, is a means to extend the capacity of a publisher.
-
Context
- The zeromq context -
Service
- The name of the forwarder - (String,
LinkType
) - access point for subscribers; usually, you want to bind the address, such that subscribers connect to it. - (String,
LinkType
) - access point for the publisher; usually, you want to connect to the publisher. -
OnError_
- Error handler -
Control
a - Control loop