summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-21 01:11:22 +0200
committerGitHub <noreply@github.com>2019-04-21 01:11:22 +0200
commit6a086a21ad64926ae1d7f494bcbcecabe1a84b23 (patch)
tree7e030bbc208d85df3bb2b1decc30ec279dc59430
parent5314ab51911787d135718c4d04fd5ffb4fa01b00 (diff)
parent4d9fb5560d37904729d7300332e413190bbb2881 (diff)
Merge pull request #9148 from vespa-engine/balder/enable-threading-as-specified
Actually use the threaded sender
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
index c3f13aeb4ae..4587c84f9dc 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
@@ -86,7 +86,7 @@ public final class VespaFeedHandler extends VespaFeedHandlerBase {
sender.addMessageProcessor(properties);
sender.addMessageProcessor(new DocprocMessageProcessor(getDocprocChain(request), getDocprocServiceRegistry(request)));
ThreadedFeedAccess feedAccess = new ThreadedFeedAccess(numThreads, sender);
- Feeder feeder = createFeeder(sender, request);
+ Feeder feeder = createFeeder(feedAccess, request);
feeder.setAbortOnDocumentError(properties.getAbortOnDocumentError());
feeder.setCreateIfNonExistent(properties.getCreateIfNonExistent());
response.setAbortOnFeedError(properties.getAbortOnFeedError());