Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2010-09-23 15:22:33 +0000
committerEike Stepper2010-09-23 15:22:33 +0000
commit3ad305914155e4884d4910235f209422c93d78f9 (patch)
tree53913b64b1743c5c8d70cc4d6fba7a55a9fee466 /plugins/org.eclipse.emf.cdo.examples/src
parent3acc1e6e1b422e3cd1b2dc5e8ac1d077266fa770 (diff)
downloadcdo-3ad305914155e4884d4910235f209422c93d78f9.tar.gz
cdo-3ad305914155e4884d4910235f209422c93d78f9.tar.xz
cdo-3ad305914155e4884d4910235f209422c93d78f9.zip
[325928] Provide FailoverMonitor server and FailoverAgents to coordinate fail-over scenarios
https://bugs.eclipse.org/bugs/show_bug.cgi?id=325928
Diffstat (limited to 'plugins/org.eclipse.emf.cdo.examples/src')
-rw-r--r--plugins/org.eclipse.emf.cdo.examples/src/org/eclipse/emf/cdo/examples/server/FailoverExample.java7
1 files changed, 3 insertions, 4 deletions
diff --git a/plugins/org.eclipse.emf.cdo.examples/src/org/eclipse/emf/cdo/examples/server/FailoverExample.java b/plugins/org.eclipse.emf.cdo.examples/src/org/eclipse/emf/cdo/examples/server/FailoverExample.java
index d64cf6a839..e51d7a8106 100644
--- a/plugins/org.eclipse.emf.cdo.examples/src/org/eclipse/emf/cdo/examples/server/FailoverExample.java
+++ b/plugins/org.eclipse.emf.cdo.examples/src/org/eclipse/emf/cdo/examples/server/FailoverExample.java
@@ -31,7 +31,6 @@ import org.eclipse.emf.cdo.server.net4j.FailoverAgent;
import org.eclipse.emf.cdo.server.net4j.FailoverMonitor;
import org.eclipse.emf.cdo.server.net4j.FailoverMonitor.AgentProtocol;
import org.eclipse.emf.cdo.session.CDOSessionConfigurationFactory;
-import org.eclipse.emf.cdo.spi.server.InternalFailoverParticipant;
import org.eclipse.emf.cdo.spi.server.InternalRepository;
import org.eclipse.net4j.Net4jUtil;
@@ -425,7 +424,7 @@ public abstract class FailoverExample
protected IRepository createRepository(IStore store, Map<String, String> props)
{
ISynchronizableRepository repository = CDOServerUtil.createFailoverParticipant(name, store, props);
- ((InternalFailoverParticipant)repository).setAllowBackupCommits(true); // Load balancing!
+ // ((InternalFailoverParticipant)repository).setAllowBackupCommits(true); // Load balancing!
FailoverAgent agent = new FailoverAgent()
{
@@ -448,8 +447,8 @@ public abstract class FailoverExample
agent.setConnectorDescription(host + ":" + port);
agent.setRepository(repository);
agent.setGroup(REPOSITORY_GROUP);
- agent.setRate(200L);
- agent.setTimeout(2000L);
+ agent.setRate(1000L);
+ agent.setTimeout(4000L);
agent.activate();
return repository;

Back to the top