Message Queue Broker

Simple message queuing broker, same as request-reply broker but using device.

 1: 
 2: 
 3: 
 4: 
 5: 
 6: 
 7: 
 8: 
 9: 
10: 
11: 
12: 
13: 
14: 
15: 
16: 
17: 
18: 
19:

#r "fszmq.dll"
open fszmq
open fszmq.Proxying

let main () =
  use context = new Context ()

  // socket facing clients
  use frontend = Context.router context
  Socket.bind frontend "tcp://*:5559"

  // socket facing services
  use backend = Context.router context
  Socket.bind backend "tcp://*:5560"

  // start the proxy
  proxy frontend backend None

  0 // return code

module docs

module PATH

from docs

val hijack : unit -> unit

Full name: docs.PATH.hijack

namespace fszmq

module Proxying

from fszmq

val main : unit -> int

Full name: Msgqueue.main

val context : 'a

val frontend : fszmq.Socket

val backend : fszmq.Socket

val proxy : frontend:fszmq.Socket -> backend:fszmq.Socket -> capture:fszmq.Socket option -> unit

Full name: fszmq.Proxying.proxy

union case Option.None: Option<'T>

val release : unit -> unit

Full name: docs.PATH.release