summaryrefslogtreecommitdiffstats
path: root/vespa_feed_perf
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2022-06-02 12:52:12 +0000
committergjoranv <gv@verizonmedia.com>2022-06-08 11:45:25 +0200
commitf2d548b013350a99c02604020eb1bfc4c2a7bf1f (patch)
tree4e9d4f25114403a5510b75cb9f4ede3996fd9548 /vespa_feed_perf
parentcf964397ea89d06916658df9b3c1c548a8960380 (diff)
remove more deprecated APIs
Diffstat (limited to 'vespa_feed_perf')
-rw-r--r--vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java6
-rw-r--r--vespa_feed_perf/src/test/java/com/yahoo/vespa/feed/perf/SimpleServer.java1
2 files changed, 4 insertions, 3 deletions
diff --git a/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java b/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
index 850513fb990..67171de487d 100644
--- a/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
+++ b/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java
@@ -2,10 +2,12 @@
package com.yahoo.vespa.feed.perf;
import com.yahoo.concurrent.ThreadFactoryFactory;
+import com.yahoo.config.subscription.ConfigSubscriber;
import com.yahoo.document.Document;
import com.yahoo.document.DocumentId;
import com.yahoo.document.DocumentPut;
import com.yahoo.document.DocumentTypeManager;
+import com.yahoo.document.DocumentTypeManagerConfigurer;
import com.yahoo.document.DocumentUpdate;
import com.yahoo.document.TestAndSetCondition;
import com.yahoo.document.json.JsonFeedReader;
@@ -63,8 +65,8 @@ import java.util.stream.Stream;
*/
public class SimpleFeeder implements ReplyHandler {
-
private final DocumentTypeManager docTypeMgr = new DocumentTypeManager();
+ private final ConfigSubscriber documentTypeConfigSubscriber;
private final List<InputStream> inputStreams;
private final PrintStream out;
private final RPCMessageBus mbus;
@@ -359,7 +361,7 @@ public class SimpleFeeder implements ReplyHandler {
numMessagesToSend = params.getNumMessagesToSend();
mbus = newMessageBus(docTypeMgr, params);
session = newSession(mbus, this, params);
- docTypeMgr.configure(params.getConfigId());
+ documentTypeConfigSubscriber = DocumentTypeManagerConfigurer.configure(docTypeMgr, params.getConfigId());
benchmarkMode = params.isBenchmarkMode();
destination = (params.getDumpStream() != null)
? createDumper(params)
diff --git a/vespa_feed_perf/src/test/java/com/yahoo/vespa/feed/perf/SimpleServer.java b/vespa_feed_perf/src/test/java/com/yahoo/vespa/feed/perf/SimpleServer.java
index ea47a58e4b7..a458a59f997 100644
--- a/vespa_feed_perf/src/test/java/com/yahoo/vespa/feed/perf/SimpleServer.java
+++ b/vespa_feed_perf/src/test/java/com/yahoo/vespa/feed/perf/SimpleServer.java
@@ -57,7 +57,6 @@ public class SimpleServer {
public final void close() {
session.destroy();
mbus.destroy();
- documentMgr.shutdown();
slobrok.stop();
}