aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2020-12-30 15:03:27 +0100
committerJon Marius Venstad <venstad@gmail.com>2021-06-30 20:50:15 +0200
commiteaed7fa806a307ca712d6f099d089288b8caaf7a (patch)
tree5978ee251f5938f5be60cebe2bfa1c679c3f4d97 /vespaclient-core
parent1991465dbd06bee5377df35dba9dd87bac787e4a (diff)
Use an injected VespaDocumentAccess for streaming search
Diffstat (limited to 'vespaclient-core')
-rw-r--r--vespaclient-core/src/main/java/com/yahoo/feedapi/MessagePropertyProcessor.java23
1 files changed, 3 insertions, 20 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/MessagePropertyProcessor.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/MessagePropertyProcessor.java
index 0a070c9fe35..113f82e1566 100644
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/MessagePropertyProcessor.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/MessagePropertyProcessor.java
@@ -4,17 +4,16 @@ package com.yahoo.feedapi;
import com.yahoo.concurrent.SystemTimer;
import com.yahoo.config.subscription.ConfigSubscriber;
import com.yahoo.container.jdisc.HttpRequest;
-import com.yahoo.vespa.config.content.LoadTypeConfig;
-import com.yahoo.documentapi.VisitorParameters;
import com.yahoo.documentapi.messagebus.loadtypes.LoadType;
import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet;
import com.yahoo.documentapi.messagebus.protocol.DocumentMessage;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
-import java.util.logging.Level;
import com.yahoo.messagebus.Message;
import com.yahoo.messagebus.routing.Route;
+import com.yahoo.vespa.config.content.LoadTypeConfig;
import com.yahoo.vespaclient.config.FeederConfig;
+import java.util.logging.Level;
import java.util.logging.Logger;
/**
@@ -247,22 +246,6 @@ public class MessagePropertyProcessor implements ConfigSubscriber.SingleSubscrib
}
}
- public void process(VisitorParameters params) {
- if (route != null) {
- params.setRoute(route);
- }
- params.setTimeoutMs(timeout);
-
- params.setTraceLevel(Math.max(getFeederOptions().getTraceLevel(), traceLevel));
-
- if (loadType != null) {
- params.setLoadType(loadType);
- params.setPriority(loadType.getPriority());
- }
-
- if (priority != null) {
- params.setPriority(priority);
- }
- }
}
+
}