summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2018-10-26 12:42:01 +0200
committerGitHub <noreply@github.com>2018-10-26 12:42:01 +0200
commitfad4f51d0a2c7b3133aff31567ef3d1475152f54 (patch)
tree832feb5f992b8e444bd6b9d04e6658f27b574ded
parent3e1c1bbf27ece0cc3846df31f13bdedf68453f18 (diff)
parent9c4421515bf7c1092eb433099e7b0cfbeecb616e (diff)
Merge pull request #7463 from vespa-engine/balder/put-back-public-api
Reinstate old visibility since imagesearch are using non-public apis.
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java6
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandlerBase.java18
2 files changed, 12 insertions, 12 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 32c2d848b82..4adfe3ebe1d 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
@@ -48,17 +48,17 @@ public final class VespaFeedHandler extends VespaFeedHandlerBase {
SlobroksConfig slobroksConfig,
ClusterListConfig clusterListConfig,
Executor executor,
- Metric metric) throws Exception {
+ Metric metric) {
super(feederConfig, loadTypeConfig, documentmanagerConfig, slobroksConfig, clusterListConfig, executor, metric);
this.maxBusyThreads = feederConfig.maxbusythreads();
}
- VespaFeedHandler(FeedContext context, Executor executor) throws Exception {
+ VespaFeedHandler(FeedContext context, Executor executor) {
super(context, executor);
this.maxBusyThreads = 32;
}
- public static VespaFeedHandler createFromContext(FeedContext context, Executor executor) throws Exception {
+ public static VespaFeedHandler createFromContext(FeedContext context, Executor executor) {
return new VespaFeedHandler(context, executor);
}
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandlerBase.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandlerBase.java
index 7dc852bfd6d..a22cbc08e38 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandlerBase.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandlerBase.java
@@ -42,29 +42,29 @@ public abstract class VespaFeedHandlerBase extends ThreadedHttpRequestHandler {
executor, (long)feederConfig.timeout() * 1000);
}
- VespaFeedHandlerBase(FeedContext context, Executor executor) {
+ public VespaFeedHandlerBase(FeedContext context, Executor executor) {
this(context, executor, context.getPropertyProcessor().getDefaultTimeoutMillis());
}
- private VespaFeedHandlerBase(FeedContext context, Executor executor, long defaultTimeoutMillis) {
+ public VespaFeedHandlerBase(FeedContext context, Executor executor, long defaultTimeoutMillis) {
super(executor, context.getMetricAPI());
this.context = context;
this.defaultTimeoutMillis = defaultTimeoutMillis;
}
- SharedSender getSharedSender(String route) {
+ public SharedSender getSharedSender(String route) {
return context.getSharedSender(route);
}
- DocprocService getDocprocChain(HttpRequest request) {
+ public DocprocService getDocprocChain(HttpRequest request) {
return context.getPropertyProcessor().getDocprocChain(request);
}
- ComponentRegistry<DocprocService> getDocprocServiceRegistry(HttpRequest request) {
+ public ComponentRegistry<DocprocService> getDocprocServiceRegistry(HttpRequest request) {
return context.getPropertyProcessor().getDocprocServiceRegistry(request);
}
- MessagePropertyProcessor getPropertyProcessor() {
+ public MessagePropertyProcessor getPropertyProcessor() {
return context.getPropertyProcessor();
}
@@ -74,7 +74,7 @@ public abstract class VespaFeedHandlerBase extends ThreadedHttpRequestHandler {
* original data stream.
* @throws IllegalArgumentException if GZIP stream creation failed
*/
- InputStream getRequestInputStream(HttpRequest request) {
+ public InputStream getRequestInputStream(HttpRequest request) {
if ("gzip".equals(request.getHeader("Content-Encoding"))) {
try {
return new GZIPInputStream(request.getData());
@@ -86,7 +86,7 @@ public abstract class VespaFeedHandlerBase extends ThreadedHttpRequestHandler {
}
}
- DocumentTypeManager getDocumentTypeManager() {
+ protected DocumentTypeManager getDocumentTypeManager() {
return context.getDocumentTypeManager();
}
@@ -94,7 +94,7 @@ public abstract class VespaFeedHandlerBase extends ThreadedHttpRequestHandler {
return context.getMetrics();
}
- long getTimeoutMillis(HttpRequest request) {
+ protected long getTimeoutMillis(HttpRequest request) {
return ParameterParser.asMilliSeconds(request.getProperty("timeout"), defaultTimeoutMillis);
}