RpcMessageQueue = ref object
  priorityQueue: AsyncQueue[seq[byte]]
  nonPriorityQueue: AsyncQueue[seq[byte]]

proc addNonPriorityMessage(aq: RpcMessageQueue; msg: seq[byte]): Future[void] {.
    stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
    tags: [RootEffect].}

proc addPriorityMessage(aq: RpcMessageQueue; msg: seq[byte]): Future[void] {.
    stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
    tags: [RootEffect].}

proc getNonPriorityMessage(rpcMessageQueue: RpcMessageQueue): Opt[seq[byte]] {.
    ...raises: [], tags: [RootEffect].}

proc getPriorityMessage(rpcMessageQueue: RpcMessageQueue): Opt[seq[byte]] {.
    ...raises: [], tags: [RootEffect].}

proc new(T: typedesc[RpcMessageQueue]): T:type {....raises: [].}