Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.englishtown.vertx.solr.impl;
 
 
Vert.x json configuration implementation
public class JsonConfigSolrConfigurator implements SolrConfigurator {
    public static final String CONFIG_CLIENT_TYPE = "client_type";
    public static final String CONFIG_SERVER_URL = "server_url";
    public static final String CONFIG_HTTP_CLIENT_OPTIONS = "http_client_options";
    public static final String DEFAULT_CLIENT_TYPE = DefaultVertxSolrClient.class.getSimpleName();
    private Vertx vertx;
    private JsonObject config;
    @Inject
    public JsonConfigSolrConfigurator(Vertx vertx) {
        this(vertxvertx.getOrCreateContext().config());
    }
    public JsonConfigSolrConfigurator(Vertx vertxJsonObject config) {
        if (config == null) {
            throw new RuntimeException("JSON config was null");
        }
        this. = config;
        this. = vertx;
    }
    @Override
    public VertxSolrClient createSolrClient() {
        if (type.equals(DefaultVertxSolrClient.class.getSimpleName())
                || type.equals(DefaultVertxSolrClient.class.getName())
                || type.equals(VertxSolrClient.class.getSimpleName())
                || type.equals(VertxSolrClient.class.getName())) {
            return createVertxSolrClient();
        } else {
            throw new IllegalArgumentException("Solr client type " + type + " is not supported.  Try the default: " + );
        }
    }
    protected VertxSolrClient createVertxSolrClient() {
        String serverUrl = .getString();
        if (serverUrl == null || serverUrl.isEmpty()) {
            throw new IllegalArgumentException("DefaultVertxSolrClient requires a " +  + " field");
        }
        JsonObject clientOptions = .getJsonObject(new JsonObject());
        return new DefaultVertxSolrClient(serverUrlnew HttpClientOptions(clientOptions));
    }
New to GrepCode? Check out our FAQ X