summaryrefslogtreecommitdiffstats
path: root/docproc
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2022-05-19 11:50:17 +0200
committergjoranv <gv@verizonmedia.com>2022-06-08 11:45:22 +0200
commit81f466444ec20a852f010624ea6fa07e50fa3e2b (patch)
treee3d2c11e0246148c12fa259d0b099853594d6da6 /docproc
parentef90737f0e313ec3fe6cd340020ccbfe73add7ec (diff)
Remove explicit operation priority from DocumentAPI session public APIs
Diffstat (limited to 'docproc')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java7
-rw-r--r--docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java2
2 files changed, 0 insertions, 9 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 c8a4b127c4e..013f75c317c 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
@@ -20,30 +20,23 @@ import java.util.logging.Logger;
/**
* @author Einar M R Rosenvinge
*/
-@SuppressWarnings("removal") // TODO: Remove on Vespa 8
class MessageFactory {
private final static Logger log = Logger.getLogger(MessageFactory.class.getName());
private final Message requestMsg;
- private final DocumentProtocol.Priority priority; // TODO: Remove on Vespa 8
- @SuppressWarnings("removal") // TODO: Remove on Vespa 8
public MessageFactory(DocumentMessage requestMsg) {
this.requestMsg = requestMsg;
- 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.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() + // TODO: Remove on Vespa 8
"', trace level = '" + message.getTrace().getLevel() +
"', time remaining = '" + message.getTimeRemaining() + "'.");
return message;
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 ad8e05c7d88..5e07b26accd 100644
--- a/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
+++ b/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
@@ -132,10 +132,8 @@ 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); // TODO: Remove on Vespa 8
msg.getTrace().setLevel(9);
msg.setTimeRemaining(60 * 1000);
return driver.client().sendMessage(msg).isAccepted();