From 4d9fb5560d37904729d7300332e413190bbb2881 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Sun, 21 Apr 2019 01:02:47 +0200 Subject: Actually use the threaded sender --- .../src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()); -- cgit v1.2.3