summaryrefslogtreecommitdiffstats
path: root/docproc
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2022-04-01 15:59:10 +0200
committerTor Brede Vekterli <vekterli@yahooinc.com>2022-04-01 15:59:10 +0200
commitdf755138e47d1ded561800978875e59094c4b1b4 (patch)
treeb6f6f7bc0259a15b5f11902e2d58c8c994e5a17e /docproc
parent14bb8f3c745f9b153e289ff62b38c911966ea32b (diff)
Deprecate DocumentAPI methods using explicit operation priority
This is functionality that made more sense when we had spinning drives and no async write scheduling in the backend. Going away on Vespa 8.
Diffstat (limited to 'docproc')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java8
-rw-r--r--docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java3
2 files changed, 7 insertions, 4 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java
index 1959ae8f339..4668942b61e 100644
--- a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java
+++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java
@@ -28,23 +28,25 @@ class MessageFactory {
private final LoadType loadType;
private final DocumentProtocol.Priority priority;
+ @SuppressWarnings("removal") // TODO: Remove on Vespa 8
public MessageFactory(DocumentMessage requestMsg) {
this.requestMsg = requestMsg;
loadType = requestMsg.getLoadType();
- priority = requestMsg.getPriority();
+ priority = requestMsg.getPriority(); // TODO: Remove on Vespa 8
}
+ @SuppressWarnings("removal") // TODO: Remove on Vespa 8
public DocumentMessage fromDocumentOperation(Processing processing, DocumentOperation documentOperation) {
DocumentMessage message = newMessage(documentOperation);
message.setLoadType(loadType);
- message.setPriority(priority);
+ message.setPriority(priority); // TODO: Remove on Vespa 8
message.setRoute(requestMsg.getRoute());
message.setTimeReceivedNow();
message.setTimeRemaining(requestMsg.getTimeRemainingNow());
message.getTrace().setLevel(requestMsg.getTrace().getLevel());
log.log(Level.FINE, () -> "Created '" + message.getClass().getName() +
"', route = '" + message.getRoute() +
- "', priority = '" + message.getPriority().name() +
+ "', priority = '" + message.getPriority().name() + // TODO: Remove on Vespa 8
"', load type = '" + message.getLoadType() +
"', trace level = '" + message.getTrace().getLevel() +
"', time remaining = '" + message.getTimeRemaining() + "'.");
diff --git a/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java b/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
index b26c5200ea9..de5cbfa505b 100644
--- a/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
+++ b/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
@@ -135,9 +135,10 @@ public abstract class DocumentProcessingHandlerTestBase {
protected abstract DocumentType getType();
+ @SuppressWarnings("removal") // TODO: Remove on Vespa 8
public boolean sendMessage(String destinationChainName, DocumentMessage msg) {
msg.setRoute(Route.parse("test/chain." + destinationChainName + " " + remoteServer.connectionSpec()));
- msg.setPriority(DocumentProtocol.Priority.HIGH_1);
+ msg.setPriority(DocumentProtocol.Priority.HIGH_1); // TODO: Remove on Vespa 8
msg.setLoadType(LoadType.DEFAULT);
msg.getTrace().setLevel(9);
msg.setTimeRemaining(60 * 1000);