/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 7776

Added by Jing Tao about 11 years ago

Use another thread in the Servlet init method to wait hazelcast.

      * @author tao
+     *
      */
     public class ApplicationController {
     public class ApplicationController implements Runnable {
         private static String SOLRINDEXES = "solrIndexes";
         private static short FIRST = 0;
         private List<SolrIndex> solrIndexes = null;
         //private List<SystemMetadataEventListener> sysmetaListeners = new ArrayList<SystemMetadataEventListener>();
         private List<SystemMetadataEventListener> sysmetaListeners = new ArrayList<SystemMetadataEventListener>();
         private static ApplicationContext context = null;
         private String springConfigFile = "src/main/resources/index-processor-context.xml";
         Log log = LogFactory.getLog(ApplicationController.class);
-...
     			// start listening for events
             	SystemMetadataEventListener smel = new SystemMetadataEventListener();
             	smel.setSolrIndex(solrIndex);
             	smel.start();
             	//sysmetaListeners.add(smel);
             	sysmetaListeners.add(smel);
             	//smel.start();
+            }
+        }
-...
         /**
          * Start to generate indexes for those haven't been indexed in another thread.
          */
         public void startIndex() {
         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();
+        }
         /**
          * Start the system metadata listener
          */
         public void startSysmetaListener() {
             if(sysmetaListeners != null) {
                 //only expects one listener.
                 for(SystemMetadataEventListener listener : sysmetaListeners) {
                     if(listener != null) {
                         listener.start();
+                    }
+                }
+            }
+        }
         /**
          * It will start system metadata event listener first. Then to generate indexes for those haven't been indexed in another thread.
          */
         public void run() {
             startSysmetaListener();
             startIndex();//it will create another thread.
+        }
+    }

             ApplicationController controller = null;
             try {
                  controller = new ApplicationController(FILEPREFIX + url.getFile());
                  //Start SystemmetadataEventListener and to generate indexes for those haven't been indexed in another thread
                  Thread sysListenerAndindexThread = new Thread(controller);
                  sysListenerAndindexThread.start();
             } catch (Exception e) {
                 throw new ServletException(e.getMessage());
+            }
             controller.startIndex();//Start to generate indexes for those haven't been indexed in another thread
             //controller.startIndex();//Start to generate indexes for those haven't been indexed in another thread
             //List<SolrIndex> list = controller.getSolrIndexes();
             //System.out.println("++++++++++++++++++++++++------------------- the size is  "+list.size());
+        }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 7776

Added by Jing Tao about 11 years ago