Simple example of consuming an EasyNetQ Advanced Bus from F#

EasyNetQAdvancedBusExample

  let messageHandlers () = 
    new Action<byte[], MessageProperties, MessageReceivedInfo>(fun message props receivedInfo ->
        let envelope = message |> Encoding.UTF8.GetString |> Envelope.Parse 
        match Model.TryParse(envelope.Topic) with
        | Some x -> 
            subject.OnNext ( pushToQueue x )
        | None -> ()
    )
          
  let queue = bus.Advanced.QueueDeclare(rabbitConfig.Queue, passive = true)
  async { 
      let q = queue
      bus.Advanced.Consume(queue = q, onMessage = messageHandlers ()) |> ignore 
  }