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 getMessage(rpcMessageQueue: RpcMessageQueue): Future[Opt[seq[byte]]] {.
    stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
    tags: [RootEffect].}

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