Apache
/
jclouds
mirror of https://github.com/apache/jclouds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Purging the request queue on context destruction to avoid lingering queued tasks

This commit is contained in:
Andrew Phillips 2011-08-08 01:12:21 -04:00
parent 9215f4fa85
commit 57c0f19b00
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
demos/tweetstore/gae-tweetstore/src/main/java/org/jclouds/demo/tweetstore/config/GuiceServletConfig.java
View File

@ -77,6 +77,7 @@ public class GuiceServletConfig extends GuiceServletContextListener {
private Map<String, BlobStoreContext> providerTypeToBlobStoreMap;
private Twitter twitterClient;
private String container;
private Queue queue;
@Override
public void contextInitialized(ServletContextEvent servletContextEvent) {
@ -110,7 +111,7 @@ public class GuiceServletConfig extends GuiceServletContextListener {
}
// get a queue for submitting store tweet requests
Queue queue = QueueFactory.getQueue("twitter");
queue = QueueFactory.getQueue("twitter");
// submit a job to store tweets for each configured blobstore
for (String name : providerTypeToBlobStoreMap.keySet()) {
queue.add(withUrl("/store/do").header("context", name).method(Method.GET));
@ -162,6 +163,7 @@ public class GuiceServletConfig extends GuiceServletContextListener {
for (BlobStoreContext context : providerTypeToBlobStoreMap.values()) {
context.close();
}
queue.purge();
super.contextDestroyed(servletContextEvent);
}
}