aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java
diff options
context:
space:
mode:
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java')
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java16
1 files changed, 3 insertions, 13 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java b/documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java
index a6648a6c89b..5c4e6c625a9 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java
@@ -4,9 +4,8 @@ package com.yahoo.documentapi;
import com.yahoo.document.DocumentOperation;
import com.yahoo.documentapi.messagebus.protocol.PutDocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.RemoveDocumentMessage;
+import com.yahoo.documentapi.messagebus.protocol.UpdateDocumentMessage;
import com.yahoo.messagebus.Message;
-import com.yahoo.vdslib.DocumentList;
-import com.yahoo.vdslib.Entry;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
@@ -18,7 +17,7 @@ import java.util.concurrent.TimeUnit;
* implements the <code>getNext</code> methods, thus implementing the polling
* API defined in VisitorDataHandler.
* <p>
- * Visitor responses containing document lists should be polled for with the
+ * Visitor responses should be polled for with the
* <code>getNext</code> methods and need to be acked when processed for
* visiting not to halt. The class is thread safe.
*
@@ -41,8 +40,7 @@ public class VisitorDataQueue extends VisitorDataHandler {
}
private void appendSingleOpToPendingList(final DocumentOperation op, final AckToken token) {
- final DocumentList docList = DocumentList.create(Entry.create(op));
- final DocumentListVisitorResponse response = new DocumentListVisitorResponse(docList, token);
+ final DocumentOpVisitorResponse response = new DocumentOpVisitorResponse(op, token);
pendingResponses.add(response);
}
@@ -59,14 +57,6 @@ public class VisitorDataQueue extends VisitorDataHandler {
}
}
- /**
- * @deprecated This method is no longer called by the visitor subsystem. See onMessage instead.
- */
- @Deprecated
- public void onDocuments(DocumentList docs, AckToken token) {
- pendingResponses.add(new DocumentListVisitorResponse(docs, token));
- }
-
// Inherit doc from VisitorDataHandler
@Override
public VisitorResponse getNext() {