svn commit: r558276 - /incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java

[antelder]

Author: antelder
Date: Sat Jul 21 02:28:07 2007
New Revision: 558276

URL: http://svn.apache.org/viewvc?view=rev&rev=558276
Log:
Conversations, fix maxage/idle expiry

Modified:
    
incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java

Modified: 
incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java
URL: 
http://svn.apache.org/viewvc/incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java?view=diff&rev=558276&r1=558275&r2=558276
==============================================================================
--- 
incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java
 (original)
+++ 
incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java
 Sat Jul 21 02:28:07 2007
@@ -31,7 +31,6 @@
 import org.apache.tuscany.sca.invocation.Message;
 import org.apache.tuscany.sca.runtime.RuntimeComponent;
 import org.apache.tuscany.sca.scope.InstanceWrapper;
-import org.apache.tuscany.sca.scope.PersistenceException;
 import org.apache.tuscany.sca.scope.Scope;
 import org.apache.tuscany.sca.scope.ScopedImplementationProvider;
 import org.apache.tuscany.sca.scope.TargetDestructionException;
@@ -90,9 +89,9 @@
              
         // Check to see if the maxAge and/or maxIdleTime have been specified 
using @ConversationAttributes.  
         // Implementation annoated attributes are honored first.
-        if (this.getComponent().getImplementation() instanceof 
ScopedImplementationProvider) 
+        if (this.getComponent().getImplementationProvider() instanceof 
ScopedImplementationProvider) 
          {
-            ScopedImplementationProvider aScopedImpl = 
(ScopedImplementationProvider) this.getComponent().getImplementation();
+            ScopedImplementationProvider aScopedImpl = 
(ScopedImplementationProvider) this.getComponent().getImplementationProvider();
             
             long maxAge = aScopedImpl.getMaxAge();
             if (maxAge > 0) {
@@ -114,7 +113,7 @@
 
         // Get a scheduler and scheduled a task to be run in the future 
indefinitely until its explicitly shutdown. 
         this.scheduler = Executors.newSingleThreadScheduledExecutor();
-        scheduler.scheduleAtFixedRate(new 
ConversationalInstanceReaper(this.instanceLifecycleCollection), 30, 
reaper_interval, TimeUnit.SECONDS);
+        scheduler.scheduleAtFixedRate(new 
ConversationalInstanceReaper(this.instanceLifecycleCollection), 3, 
reaper_interval, TimeUnit.SECONDS);
         
         lifecycleState = RUNNING;        
        }



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]