diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2020-12-30 15:03:27 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-06-30 20:50:15 +0200 |
commit | eaed7fa806a307ca712d6f099d089288b8caaf7a (patch) | |
tree | 5978ee251f5938f5be60cebe2bfa1c679c3f4d97 /vespaclient-core | |
parent | 1991465dbd06bee5377df35dba9dd87bac787e4a (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.java | 23 |
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); - } - } } + } |