package compbio.listeners;
+import java.io.IOException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
-import compbio.cassandra.CassandraCreate;
+import compbio.cassandra.CassandraNativeConnector;
/**
* Application Lifecycle Listener implementation class ContextListener
@WebListener
public class ContextListener implements ServletContextListener {
private ScheduledExecutorService webjob_scheduler;
- //private ScheduledExecutorService localjob_scheduler;
- CassandraCreate cc = new CassandraCreate();
+ CassandraNativeConnector db = new CassandraNativeConnector();
/**
* @see ServletContextListener#contextInitialized(ServletContextEvent)
*/
public void contextInitialized(ServletContextEvent arg0) {
System.out.println("ProteoCache session start......");
- cc.Connection();
+ db.Connect();
webjob_scheduler = Executors.newSingleThreadScheduledExecutor();
webjob_scheduler.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
- cc.Parsing("http");
- //cc.Parsing("file");
+ try {
+ db.Parsing();
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
}
- }, 0, 20, TimeUnit.SECONDS);
-/*
- localjob_scheduler = Executors.newSingleThreadScheduledExecutor();
- localjob_scheduler.scheduleAtFixedRate(new Runnable() {
- @Override
- public void run() {
- cc.Parsing("http");
- //cc.Parsing("file");
- }
- }, 0, 20000, TimeUnit.SECONDS);
-*/
+ }, 0, 60, TimeUnit.SECONDS);
+
}
/**
* @see ServletContextListener#contextDestroyed(ServletContextEvent)
*/
public void contextDestroyed(ServletContextEvent arg0) {
- cc.Closing();
+ db.Closing();
System.out.println("Shut down ProteoCache......");
webjob_scheduler.shutdownNow();
- //localjob_scheduler.shutdownNow();
}
}