diff options
author | Eike Stepper | 2008-09-22 09:20:06 +0000 |
---|---|---|
committer | Eike Stepper | 2008-09-22 09:20:06 +0000 |
commit | 91cf0441c6eec7922615a0bde10d31cb7ccf5f7b (patch) | |
tree | ba551831427f0b232b1295f123c0fab7b41f4420 /plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java | |
parent | 5f8e5f6c696fac456ede5cd5162449beb486e1d4 (diff) | |
download | cdo-91cf0441c6eec7922615a0bde10d31cb7ccf5f7b.tar.gz cdo-91cf0441c6eec7922615a0bde10d31cb7ccf5f7b.tar.xz cdo-91cf0441c6eec7922615a0bde10d31cb7ccf5f7b.zip |
[247817] Develop configurable test bed
https://bugs.eclipse.org/bugs/show_bug.cgi?id=247817
Diffstat (limited to 'plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java')
-rw-r--r-- | plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java index dc2cc04632..205af5c86a 100644 --- a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java +++ b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/CommitManager.java @@ -11,6 +11,7 @@ package org.eclipse.emf.cdo.internal.server; import org.eclipse.emf.cdo.internal.server.Transaction.InternalCommitContext; +import org.eclipse.emf.cdo.server.IRepository; import org.eclipse.emf.cdo.server.IRepositoryElement; import org.eclipse.net4j.util.lifecycle.Lifecycle; @@ -29,22 +30,26 @@ import java.util.concurrent.Future; */ public class CommitManager extends Lifecycle implements IRepositoryElement { - private Repository repository; + private IRepository repository; private ExecutorService executors; private Map<Transaction, TransactionCommitContextEntry> commitContextMap = new ConcurrentHashMap<Transaction, TransactionCommitContextEntry>(); - public CommitManager(Repository repository) + public CommitManager() { - this.repository = repository; } - public Repository getRepository() + public IRepository getRepository() { return repository; } + public void setRepository(IRepository repository) + { + this.repository = repository; + } + public synchronized ExecutorService getExecutors() { if (executors == null) |