summaryrefslogtreecommitdiffstats
path: root/docproc
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2022-05-16 13:20:56 +0200
committergjoranv <gv@verizonmedia.com>2022-06-08 11:45:22 +0200
commit4639be4f03d58a0b8df7b1ecb573e7d344a53ed5 (patch)
tree236d8b271e2e51c5e15df08bc19c4c97860ca16a /docproc
parent1e03a00cd6f69cf63d942885e97ff7582778c7f5 (diff)
Remove top-level <clients> element and LoadType concept
Load types have not been properly supported for some time, so remove the remaining API surfaces exposing them. Since load type config was the last remaining use of <clients> in services.xml, remove that one as well.
Diffstat (limited to 'docproc')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MessageFactory.java5
-rw-r--r--docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java4
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 1fe6d4cc86c..c8a4b127c4e 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
@@ -6,7 +6,6 @@ import com.yahoo.document.DocumentOperation;
import com.yahoo.document.DocumentPut;
import com.yahoo.document.DocumentRemove;
import com.yahoo.document.DocumentUpdate;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadType;
import com.yahoo.documentapi.messagebus.protocol.DocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
import com.yahoo.documentapi.messagebus.protocol.PutDocumentMessage;
@@ -26,20 +25,17 @@ class MessageFactory {
private final static Logger log = Logger.getLogger(MessageFactory.class.getName());
private final Message requestMsg;
- private final LoadType loadType; // TODO: Remove on Vespa 8
private final DocumentProtocol.Priority priority; // TODO: Remove on Vespa 8
@SuppressWarnings("removal") // TODO: Remove on Vespa 8
public MessageFactory(DocumentMessage requestMsg) {
this.requestMsg = requestMsg;
- loadType = requestMsg.getLoadType();
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); // TODO: Remove on Vespa 8
message.setRoute(requestMsg.getRoute());
message.setTimeReceivedNow();
@@ -48,7 +44,6 @@ class MessageFactory {
log.log(Level.FINE, () -> "Created '" + message.getClass().getName() +
"', route = '" + message.getRoute() +
"', priority = '" + message.getPriority().name() + // TODO: Remove on Vespa 8
- "', load type = '" + message.getLoadType() +
"', 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 de5cbfa505b..ad8e05c7d88 100644
--- a/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
+++ b/docproc/src/test/java/com/yahoo/docproc/jdisc/DocumentProcessingHandlerTestBase.java
@@ -17,7 +17,6 @@ import com.yahoo.docproc.jdisc.messagebus.MbusRequestContext;
import com.yahoo.document.DocumentType;
import com.yahoo.document.DocumentTypeManager;
import com.yahoo.document.config.DocumentmanagerConfig;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadType;
import com.yahoo.documentapi.messagebus.protocol.DocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocolPoliciesConfig;
@@ -34,8 +33,6 @@ import com.yahoo.messagebus.network.NetworkMultiplexer;
import com.yahoo.messagebus.network.rpc.RPCNetwork;
import com.yahoo.messagebus.routing.Route;
import com.yahoo.messagebus.shared.SharedSourceSession;
-import com.yahoo.vespa.config.content.DistributionConfig;
-import com.yahoo.vespa.config.content.LoadTypeConfig;
import org.junit.After;
import org.junit.Before;
@@ -139,7 +136,6 @@ public abstract class DocumentProcessingHandlerTestBase {
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.setLoadType(LoadType.DEFAULT);
msg.getTrace().setLevel(9);
msg.setTimeRemaining(60 * 1000);
return driver.client().sendMessage(msg).isAccepted();