Add new still not-working code for native binary protocol version

[proteocache.git] / server / compbio / listeners / ContextListener.java

diff --git a/server/compbio/listeners/ContextListener.java b/server/compbio/listeners/ContextListener.java
index 2dfe373..44cf66b 100644 (file)
--- a/server/compbio/listeners/ContextListener.java
+++ b/server/compbio/listeners/ContextListener.java
@@ -1,5 +1,6 @@
 package compbio.listeners;
 
+import java.io.IOException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
@@ -8,7 +9,7 @@ import javax.servlet.ServletContextEvent;
 import javax.servlet.ServletContextListener;
 import javax.servlet.annotation.WebListener;
 
-import compbio.cassandra.CassandraCreate;
+import compbio.cassandra.CassandraNativeConnector;
 
 /**
  * Application Lifecycle Listener implementation class ContextListener
@@ -16,32 +17,38 @@ import compbio.cassandra.CassandraCreate;
  */
 @WebListener
 public class ContextListener implements ServletContextListener {
-       private ScheduledExecutorService scheduler;
-       CassandraCreate cc = new CassandraCreate();
+       private ScheduledExecutorService webjob_scheduler;
+       CassandraNativeConnector db = new CassandraNativeConnector();
 
        /**
         * @see ServletContextListener#contextInitialized(ServletContextEvent)
         */
        public void contextInitialized(ServletContextEvent arg0) {
                System.out.println("ProteoCache session start......");
-               cc.Connection();
+               db.Connect();
 
-               scheduler = Executors.newSingleThreadScheduledExecutor();
-               scheduler.scheduleAtFixedRate(new Runnable() {
+               webjob_scheduler = Executors.newSingleThreadScheduledExecutor();
+               webjob_scheduler.scheduleAtFixedRate(new Runnable() {
                        @Override
                        public void run() {
-                               cc.Parsing();
+                               try {
+                                       db.Parsing();
+                               } catch (IOException e) {
+                                       // TODO Auto-generated catch block
+                                       e.printStackTrace();
+                               }
                        }
                }, 0, 60, TimeUnit.SECONDS);
+
        }
 
        /**
         * @see ServletContextListener#contextDestroyed(ServletContextEvent)
         */
        public void contextDestroyed(ServletContextEvent arg0) {
-               cc.Closing();
+               db.Closing();
                System.out.println("Shut down ProteoCache......");
-               scheduler.shutdownNow();
+               webjob_scheduler.shutdownNow();
        }
 
 }