X-Git-Url: https://code.grnet.gr/git/pithos/blobdiff_plain/0fcbf8bda39348ef24384c3d4f6ad8bf5e4150eb..3efe89839014b451b4b44001aba801ee35687c23:/src/gr/ebs/gss/server/ejb/indexer/IndexerMDBean.java

diff --git a/src/gr/ebs/gss/server/ejb/indexer/IndexerMDBean.java b/src/gr/ebs/gss/server/ejb/indexer/IndexerMDBean.java
index 2cca442..d525f38 100644
--- a/src/gr/ebs/gss/server/ejb/indexer/IndexerMDBean.java
+++ b/src/gr/ebs/gss/server/ejb/indexer/IndexerMDBean.java
@@ -97,10 +97,13 @@ public class IndexerMDBean implements MessageListener {
 			id = (Long) map.getObject("id");
 			boolean delete = map.getBoolean("delete");
 			Configuration config = GSSConfigurationFactory.getConfiguration();
-			if (delete) {
-				sendDelete(config.getString("solr.url"), id);
+            CommonsHttpSolrServer solr = new CommonsHttpSolrServer(getConfiguration().getString("solr.url"));
+            if (delete) {
+				sendDelete(solr, id);
+                solr.commit();
 			} else {
-				service.postFileToSolr(id);
+				service.postFileToSolr(solr, id);
+                solr.commit();
 			}	
 		}
 		catch (JMSException e) {
@@ -118,16 +121,12 @@ public class IndexerMDBean implements MessageListener {
 	/**
 	 * Sends a delete command to solr. The id is the Long id of the indexed document
 	 * 
-	 * @param solrUrl
+	 * @param solr
 	 * @param id
 	 * @throws SolrServerException
 	 * @throws IOException
 	 */
-	private void sendDelete(String solrUrl, Long id)	throws SolrServerException, IOException {
-		CommonsHttpSolrServer solr = new CommonsHttpSolrServer(solrUrl);
+	private void sendDelete(CommonsHttpSolrServer solr, Long id)	throws SolrServerException, IOException {
 		solr.deleteById(id.toString());
-		solr.commit();
 	}
-
-
 }