svn commit: r1448550 [6/6] - in /jackrabbit/oak/trunk: ./ oak-parent/ oak-solr-core/ oak-solr-core/src/ oak-solr-core/src/main/ oak-solr-core/src/main/java/ oak-solr-core/src/main/java/org/ oak-solr-core/src/main/java/org/apache/ oak-solr-core/src/main...

[to...@apache.org]

Added: jackrabbit/oak/trunk/oak-solr-remote/src/main/java/org/apache/jackrabbit/oak/plugins/index/solr/http/RemoteSolrServerProvider.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-solr-remote/src/main/java/org/apache/jackrabbit/oak/plugins/index/solr/http/RemoteSolrServerProvider.java?rev=1448550&view=auto
==============================================================================
--- jackrabbit/oak/trunk/oak-solr-remote/src/main/java/org/apache/jackrabbit/oak/plugins/index/solr/http/RemoteSolrServerProvider.java (added)
+++ jackrabbit/oak/trunk/oak-solr-remote/src/main/java/org/apache/jackrabbit/oak/plugins/index/solr/http/RemoteSolrServerProvider.java Thu Feb 21 08:51:30 2013
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.jackrabbit.oak.plugins.index.solr.http;
+
+import java.io.IOException;
+
+import org.apache.felix.scr.annotations.Activate;
+import org.apache.felix.scr.annotations.Component;
+import org.apache.felix.scr.annotations.Deactivate;
+import org.apache.felix.scr.annotations.Property;
+import org.apache.felix.scr.annotations.Service;
+import org.apache.jackrabbit.oak.plugins.index.solr.OakSolrUtils;
+import org.apache.jackrabbit.oak.plugins.index.solr.SolrServerProvider;
+import org.apache.solr.client.solrj.SolrServer;
+import org.apache.solr.client.solrj.SolrServerException;
+import org.apache.solr.client.solrj.impl.CloudSolrServer;
+import org.apache.solr.client.solrj.impl.HttpSolrServer;
+import org.osgi.service.component.ComponentContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * {@link SolrServerProvider} for remote Solr installations.
+ */
+@Component(metatype = true, immediate = true)
+@Service(SolrServerProvider.class)
+public class RemoteSolrServerProvider implements SolrServerProvider {
+
+    private final Logger log = LoggerFactory.getLogger(RemoteSolrServerProvider.class);
+
+    private static final String DEFAULT_COLLECTION = "oak";
+
+    @Property(value = "http://127.0.0.1:8983/solr")
+    private static final String SOLR_HTTP_URL = "solr.http.url";
+
+    @Property(value = "localhost:9983")
+    private static final String SOLR_ZK_HOST = "solr.zk.host";
+
+    private SolrServer solrServer;
+    private String solrHttpUrl;
+    private String solrZkHost;
+
+    @Activate
+    protected void activate(ComponentContext componentContext) throws Exception {
+        solrHttpUrl = String.valueOf(componentContext.getProperties().get(SOLR_HTTP_URL));
+        solrZkHost = String.valueOf(componentContext.getProperties().get(SOLR_ZK_HOST));
+    }
+
+    @Deactivate
+    protected void deactivate() throws Exception {
+        solrHttpUrl = null;
+        solrZkHost = null;
+        if (solrServer != null) {
+            solrServer.shutdown();
+            solrServer = null;
+        }
+    }
+
+
+    @Override
+    public SolrServer getSolrServer() throws Exception {
+        if (solrServer == null) {
+            try {
+                solrServer = initializeWithCloudSolrServer();
+            } catch (Exception e) {
+                log.warn("unable to initialize default SolrCloud client");
+                try {
+                    solrServer = initializeWithExistingHttpServer();
+                } catch (Exception e1) {
+                    log.warn("unable to initialize default Solr HTTP client");
+                }
+            }
+            if (solrServer == null) {
+                throw new IOException("could not connect to any HTTP Solr server");
+            }
+        }
+        return solrServer;
+    }
+
+    private SolrServer initializeWithExistingHttpServer() throws IOException, SolrServerException {
+        // try basic Solr HTTP client
+        HttpSolrServer httpSolrServer = new HttpSolrServer(solrHttpUrl);
+        if (OakSolrUtils.checkServerAlive(httpSolrServer)) {
+            // TODO : check if oak collection exists, otherwise create it
+            return httpSolrServer;
+        } else {
+            throw new IOException("the found HTTP Solr server is not alive");
+        }
+
+    }
+
+    private SolrServer initializeWithCloudSolrServer() throws IOException, SolrServerException {
+        // try SolrCloud client
+        CloudSolrServer cloudSolrServer = new CloudSolrServer(solrZkHost);
+        cloudSolrServer.setDefaultCollection(DEFAULT_COLLECTION);
+        if (OakSolrUtils.checkServerAlive(cloudSolrServer)) {
+            // TODO : check if oak collection exists, otherwise create it
+            return cloudSolrServer;
+        } else {
+            throw new IOException("the found SolrCloud server is not alive");
+        }
+    }
+}

Propchange: jackrabbit/oak/trunk/oak-solr-remote/src/main/java/org/apache/jackrabbit/oak/plugins/index/solr/http/RemoteSolrServerProvider.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: jackrabbit/oak/trunk/pom.xml
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/pom.xml?rev=1448550&r1=1448549&r2=1448550&view=diff
==============================================================================
--- jackrabbit/oak/trunk/pom.xml (original)
+++ jackrabbit/oak/trunk/pom.xml Thu Feb 21 08:51:30 2013
@@ -47,6 +47,9 @@
     <module>oak-sling</module>
     <module>oak-http</module>
     <module>oak-lucene</module>
+    <module>oak-solr-core</module>
+    <module>oak-solr-remote</module>
+    <module>oak-solr-embedded</module>
     <module>oak-run</module>
     <module>oak-it</module>
     <module>oak-mk-perf</module>