User: thedug
Date: 01/06/01 00:44:52
Modified: src/main/org/jboss/ejb/plugins
EntitySynchronizationInterceptor.java
Log:
Added support for commit option D dynamically configured refresh rate
Revision Changes Path
1.33 +11 -11
jboss/src/main/org/jboss/ejb/plugins/EntitySynchronizationInterceptor.java
Index: EntitySynchronizationInterceptor.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/EntitySynchronizationInterceptor.java,v
retrieving revision 1.32
retrieving revision 1.33
diff -u -r1.32 -r1.33
--- EntitySynchronizationInterceptor.java 2001/05/31 23:50:47 1.32
+++ EntitySynchronizationInterceptor.java 2001/06/01 07:44:52 1.33
@@ -49,7 +49,7 @@
* @see <related>
* @author Rickard Öberg ([EMAIL PROTECTED])
* @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
-* @version $Revision: 1.32 $
+* @version $Revision: 1.33 $
*/
public class EntitySynchronizationInterceptor
extends AbstractInterceptor
@@ -64,6 +64,11 @@
protected int commitOption;
/**
+ * The refresh rate for commit option d
+ */
+ protected long optionDRefreshRate;
+
+ /**
* The container of this interceptor.
*/
protected EntityContainer container;
@@ -95,14 +100,15 @@
try{
validContexts = new HashSet();
- commitOption =
container.getBeanMetaData().getContainerConfiguration().getCommitOption();
+ ConfigurationMetaData configuration =
container.getBeanMetaData().getContainerConfiguration();
+ commitOption = configuration.getCommitOption();
+ optionDRefreshRate = configuration.getOptionDRefreshRate();
//start up the validContexts thread if commit option D
if(commitOption == ConfigurationMetaData.D_COMMIT_OPTION){
- ValidContextsRefresher vcr = new ValidContextsRefresher(validContexts);
+ ValidContextsRefresher vcr = new ValidContextsRefresher(validContexts,
optionDRefreshRate);
new Thread(vcr).start();
- }
-
+ }
isModified = container.getBeanClass().getMethod("isModified", new
Class[0]);
if (!isModified.getReturnType().equals(Boolean.TYPE))
@@ -470,16 +476,10 @@
class ValidContextsRefresher implements Runnable{
private HashSet validContexts;
private long refreshRate;
- private final int THIRTY_SECS = 30000;
public ValidContextsRefresher(HashSet validContexts,long refreshRate){
this.validContexts = validContexts;
this.refreshRate = refreshRate;
- }
-
- public ValidContextsRefresher(HashSet validContexts){
- this(validContexts, THIRTY_SECS);
-
}
public void run(){
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
