let resendErrorsAsync (bus: IBus) (errorQueueName: string) =
  async {
      let! errorQueue = bus.Advanced.QueueDeclareAsync(errorQueueName) |> Async.AwaitTask
      let! message = bus.Advanced.GetMessageAsync(errorQueue) |> Async.AwaitTask
      while message <> null do
          let utf8Body = Encoding.UTF8.GetString(message.Body)
          let error = JsonConvert.DeserializeObject<Error>(utf8Body)
          let errorBodyBytes = Encoding.UTF8.GetBytes(error.Message)
          let! exchange = bus.Advanced.ExchangeDeclareAsync(error.Exchange, "topic") |> Async.AwaitTask
          let! message = bus.Advanced.GetMessageAsync(errorQueue) |> Async.AwaitTask
          ()
  }