aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java')
-rw-r--r--documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java24
1 files changed, 9 insertions, 15 deletions
diff --git a/documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java b/documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java
index fbe2abf2e20..7cd8cf05c8e 100644
--- a/documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java
+++ b/documentapi/src/test/java/com/yahoo/documentapi/VisitorDataQueueTest.java
@@ -10,7 +10,6 @@ import com.yahoo.document.DocumentTypeManagerConfigurer;
import com.yahoo.documentapi.messagebus.protocol.GetDocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.PutDocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.RemoveDocumentMessage;
-import com.yahoo.vdslib.Entry;
import org.junit.Before;
import org.junit.Test;
@@ -42,17 +41,15 @@ public class VisitorDataQueueTest {
return new AckToken(new Object());
}
- private static void assertNonNullDocumentListResponse(final VisitorResponse response) {
+ private static void assertNonNullDocumentOpResponse(final VisitorResponse response) {
assertThat(response, notNullValue());
- assertThat(response, instanceOf(DocumentListVisitorResponse.class));
+ assertThat(response, instanceOf(DocumentOpVisitorResponse.class));
}
private static void assertResponseHasSinglePut(final VisitorResponse response, final DocumentPut expectedInstance) {
- assertNonNullDocumentListResponse(response);
- final DocumentListVisitorResponse visitorResponse = (DocumentListVisitorResponse)response;
- assertThat(visitorResponse.getDocumentList().size(), equalTo(1));
- final Entry entry = visitorResponse.getDocumentList().get(0);
- assertThat(entry.getDocumentOperation(), is(expectedInstance));
+ assertNonNullDocumentOpResponse(response);
+ final DocumentOpVisitorResponse visitorResponse = (DocumentOpVisitorResponse)response;
+ assertThat(visitorResponse.getDocumentOperation(), is(expectedInstance));
}
@Test
@@ -78,13 +75,10 @@ public class VisitorDataQueueTest {
}
private static void assertResponseHasSingleRemove(final VisitorResponse response, final String docId) {
- assertNonNullDocumentListResponse(response);
- final DocumentListVisitorResponse visitorResponse = (DocumentListVisitorResponse)response;
- assertThat(visitorResponse.getDocumentList().size(), equalTo(1));
- final Entry entry = visitorResponse.getDocumentList().get(0);
- assertThat(entry.isRemoveEntry(), is(true));
- assertThat(entry.getDocumentOperation(), instanceOf(DocumentRemove.class));
- assertThat(entry.getDocumentOperation().getId(), equalTo(new DocumentId(docId)));
+ assertNonNullDocumentOpResponse(response);
+ final DocumentOpVisitorResponse visitorResponse = (DocumentOpVisitorResponse)response;
+ assertThat(visitorResponse.getDocumentOperation(), instanceOf(DocumentRemove.class));
+ assertThat(visitorResponse.getDocumentOperation().getId(), equalTo(new DocumentId(docId)));
}
@Test