diff options
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java')
-rw-r--r-- | documentapi/src/main/java/com/yahoo/documentapi/VisitorDataQueue.java | 16 |
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() { |