/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 7788

Added by Jing Tao about 11 years ago

Set up a Timer to run the regenerating solr index task periodically.

     import java.io.File;
     import java.util.ArrayList;
     import java.util.List;
     import java.util.Timer;
     import javax.servlet.ServletConfig;
     import javax.servlet.ServletException;
-...
     import org.springframework.context.support.FileSystemXmlApplicationContext;
     import com.hazelcast.client.HazelcastClient;
     import com.ibm.icu.util.Calendar;
     /**
      * The start class of the index.
-...
      */
     public class ApplicationController implements Runnable {
         private static long DEFAULTINTERVAL = 7200000;
         private static String SOLRINDEXES = "solrIndexes";
         private static short FIRST = 0;
-...
         private String metacatPropertiesFile = null;
         private static int waitingTime = IndexGenerator.WAITTIME;
         private static int maxAttempts = IndexGenerator.MAXWAITNUMBER;
         private static long period = DEFAULTINTERVAL;
         Log log = LogFactory.getLog(ApplicationController.class);
-...
          */
         private void initializeSharedConfiguration() {
             int times = 0;
             boolean foundProperty = false;
             while(true) {
                 File metacatProperties = new File(metacatPropertiesFile);
                 if(metacatProperties.exists()) {
                     foundProperty = true;
                     break;
                 } else {
                     try {
-...
                 //if we don't set this property, d1_cn_index_processor will use the default location /etc/dataone/storage.
                 Settings.getConfiguration().setProperty("dataone.hazelcast.location.clientconfig", hzConfigFileName);
+            }
             if(foundProperty) {
                 period = Settings.getConfiguration().getLong("index.regenerate.interval");
+            }
+        }
         /**
-...
         /**
          * Start to generate indexes for those haven't been indexed in another thread.
          * It will create a timer to run this task periodically.
          * If the property of "index.regenerate.interval" is less than 0, the thread would NOT run.
          */
         private void startIndex() {
             SolrIndex index = solrIndexes.get(FIRST);
             //SystemMetadataEventListener listener = sysmetaListeners.get(FIRST);
             IndexGenerator generator = new IndexGenerator(index);
             Thread indexThread = new Thread(generator);
             indexThread.start();
             if(period > 0) {
                 SolrIndex index = solrIndexes.get(FIRST);
                 //SystemMetadataEventListener listener = sysmetaListeners.get(FIRST);
                 IndexGenerator generator = new IndexGenerator(index);
                 //Thread indexThread = new Thread(generator);
                 //indexThread.start();
                 Timer indexTimer = new Timer();
                 indexTimer.scheduleAtFixedRate(generator, Calendar.getInstance().getTime(), period);
+            }
+        }
         /**

     import java.util.ArrayList;
     import java.util.Date;
     import java.util.List;
     import java.util.TimerTask;
     import java.util.Vector;
     import org.apache.commons.logging.Log;
-...
      * @author tao
+     *
      */
     public class IndexGenerator implements Runnable {
     public class IndexGenerator extends TimerTask {
         private static final int FIRST =0;
         private static final int SECOND =1;
-...
+            }
             return obsoletes;
+        }
         /**
          * Overwrite and do nothing
          */
         public boolean cancel() {
             return true;
+        }
+    }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 7788

Added by Jing Tao about 11 years ago