code: @Override
    public void reset() {
      ReflectorMessageQueue msgQueue = reflector(ReflectorMessageQueue.class, realQueue);
      msgQueue.setMessages(null);
      msgQueue.setIdleHandlers(new ArrayList<>());
      msgQueue.setNextBarrierToken(0);
    }
docs: so it should be package private