You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by an...@apache.org on 2007/07/21 11:28:08 UTC
svn commit: r558276 -
/incubator/tuscany/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/scope/ConversationalScopeContainer.java
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: tuscany-commits-unsubscribe@ws.apache.org
For additional commands, e-mail: tuscany-commits-help@ws.apache.org