summaryrefslogtreecommitdiffstats
path: root/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java33
1 files changed, 5 insertions, 28 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
index 6adc8a2299a..896812b58e7 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SingleSender.java
@@ -1,11 +1,9 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.feedapi;
-import com.yahoo.document.Document;
-import com.yahoo.document.DocumentId;
import com.yahoo.document.DocumentPut;
+import com.yahoo.document.DocumentRemove;
import com.yahoo.document.DocumentUpdate;
-import com.yahoo.document.TestAndSetCondition;
import com.yahoo.documentapi.messagebus.protocol.PutDocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.RemoveDocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.UpdateDocumentMessage;
@@ -26,13 +24,13 @@ public class SingleSender implements SimpleFeedAccess {
}
@Override
- public void put(Document doc) {
- send(new PutDocumentMessage(new DocumentPut(doc)));
+ public void put(DocumentPut put) {
+ send(new PutDocumentMessage(put));
}
@Override
- public void remove(DocumentId docId) {
- send(new RemoveDocumentMessage(docId));
+ public void remove(DocumentRemove remove) {
+ send(new RemoveDocumentMessage(remove));
}
@Override
@@ -41,27 +39,6 @@ public class SingleSender implements SimpleFeedAccess {
}
@Override
- public void put(Document doc, TestAndSetCondition condition) {
- PutDocumentMessage message = new PutDocumentMessage(new DocumentPut(doc));
- message.setCondition(condition);
- send(message);
- }
-
- @Override
- public void remove(DocumentId docId, TestAndSetCondition condition) {
- RemoveDocumentMessage message = new RemoveDocumentMessage(docId);
- message.setCondition(condition);
- send(message);
- }
-
- @Override
- public void update(DocumentUpdate update, TestAndSetCondition condition) {
- UpdateDocumentMessage message = new UpdateDocumentMessage(update);
- message.setCondition(condition);
- send(message);
- }
-
- @Override
public boolean isAborted() {
return owner.isAborted();
}