@Test
    @SuppressWarnings("removal")
    void testSendSingleMessage() throws DocumentRetrieverException {
        ClientParameters params = createParameters()
                .setDocumentIds(asIterator(DOC_ID_1))
                .setPriority(DocumentProtocol.Priority.HIGH_1)
                .setNoRetry(true)
                .build();

        when(mockedSession.syncSend(any())).thenReturn(createDocumentReply(DOC_ID_1));

        DocumentRetriever documentRetriever = new DocumentRetriever(
                new ClusterList(),
                mockedFactory,
                params);
        documentRetriever.retrieveDocuments();

        verify(mockedSession, times(1)).syncSend(argThat((ArgumentMatcher<GetDocumentMessage>) o ->
                o.getPriority().equals(DocumentProtocol.Priority.HIGH_1) && // TODO remove on Vespa 9
                        !o.getRetryEnabled()));
        assertContainsDocument(DOC_ID_1);
    }
Test class for {@link DocumentRetriever}

@author bjorncs
vespaclient-java/src/test/java/com/yahoo/vespaget/DocumentRetrieverTest.java