You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cvs@cocoon.apache.org by gi...@apache.org on 2005/12/27 23:56:04 UTC

svn commit: r359314 - /cocoon/trunk/src/java/org/apache/cocoon/components/flow/ContinuationsManagerImpl.java

Author: giacomo
Date: Tue Dec 27 14:56:01 2005
New Revision: 359314

URL: http://svn.apache.org/viewcvs?rev=359314&view=rev
Log:
new MBean (initial)

Modified:
    cocoon/trunk/src/java/org/apache/cocoon/components/flow/ContinuationsManagerImpl.java

Modified: cocoon/trunk/src/java/org/apache/cocoon/components/flow/ContinuationsManagerImpl.java
URL: http://svn.apache.org/viewcvs/cocoon/trunk/src/java/org/apache/cocoon/components/flow/ContinuationsManagerImpl.java?rev=359314&r1=359313&r2=359314&view=diff
==============================================================================
--- cocoon/trunk/src/java/org/apache/cocoon/components/flow/ContinuationsManagerImpl.java (original)
+++ cocoon/trunk/src/java/org/apache/cocoon/components/flow/ContinuationsManagerImpl.java Tue Dec 27 14:56:01 2005
@@ -110,6 +110,8 @@
     protected ServiceManager serviceManager;
     protected Context context;
 
+    protected long expirationCheckInterval;
+    
     public ContinuationsManagerImpl() throws Exception {
         try {
             random = SecureRandom.getInstance("SHA1PRNG");
@@ -135,7 +137,7 @@
         
         final Configuration expireConf = config.getChild("expirations-check");
         final long initialDelay = expireConf.getChild("offset", true).getValueAsLong(180000);
-        final long interval = expireConf.getChild("period", true).getValueAsLong(180000);
+        this.expirationCheckInterval = expireConf.getChild("period", true).getValueAsLong(180000);
         try {
             final RunnableManager runnableManager = (RunnableManager)serviceManager.lookup(RunnableManager.ROLE);
             runnableManager.execute( new Runnable() {
@@ -143,7 +145,7 @@
                     {
                         expireContinuations();
                     }
-                }, initialDelay, interval);
+                }, initialDelay, expirationCheckInterval);
             serviceManager.release(runnableManager);
         } catch (Exception e) {
             getLogger().warn("Could not enqueue continuations expiration task. " +