summaryrefslogtreecommitdiffstats
path: root/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java')
-rw-r--r--vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java7
1 files changed, 3 insertions, 4 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
index e354cba141d..19d074a0ead 100644
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
@@ -10,8 +10,8 @@ import java.util.List;
import javax.xml.stream.XMLStreamException;
import com.yahoo.document.DocumentTypeManager;
+import com.yahoo.vespaxmlparser.FeedOperation;
import com.yahoo.vespaxmlparser.FeedReader;
-import com.yahoo.vespaxmlparser.VespaXMLFeedReader;
/**
* Base class for unpacking document operation streams and pushing to feed
@@ -80,14 +80,13 @@ public abstract class Feeder {
while (!sender.isAborted()) {
try {
- VespaXMLFeedReader.Operation op = new VespaXMLFeedReader.Operation();
- reader.read(op);
+ FeedOperation op = reader.read();
if (createIfNonExistent && op.getDocumentUpdate() != null) {
op.getDocumentUpdate().setCreateIfNonExistent(true);
}
// Done feeding.
- if (op.getType() == VespaXMLFeedReader.OperationType.INVALID) {
+ if (op.getType() == FeedOperation.Type.INVALID) {
break;
} else {
sender.sendOperation(op);