# added replication tests

This commit is contained in:
Lukas Niemeier committed 2013-10-29 22:17:51 +01:00
1 parent 5230799349
commit e94dcf286e
3 files changed
+38 -3

No files matched your search

@@ -1,11 +1,12 @@
package com.sap.sailing.domain.base.configuration;
import java.io.Serializable;
import java.util.List;
/**
* Interface holding information about tablet's (RCApp) configuration.
*/
public interface DeviceConfiguration {
public interface DeviceConfiguration extends Serializable {
List<String> getAllowedCourseAreaNames();
Integer getMinimumRoundsForCourse();
Integer getMaximumRoundsForCourse();
@@ -4,6 +4,8 @@ import java.util.List;
import com.sap.sailing.domain.base.configuration.DeviceConfiguration;
public class DeviceConfigurationImpl implements DeviceConfiguration {
private static final long serialVersionUID = 6084215932610324314L;
private List<String> allowedCourseAreaNames;
private Integer minRounds;
@@ -10,18 +10,50 @@ import com.sap.sailing.domain.base.configuration.DeviceConfiguration;
import com.sap.sailing.domain.base.configuration.DeviceConfigurationMatcher;
import com.sap.sailing.domain.base.configuration.impl.DeviceConfigurationImpl;
import com.sap.sailing.domain.base.configuration.impl.DeviceConfigurationMatcherAny;
import com.sap.sailing.domain.base.configuration.impl.DeviceConfigurationMatcherSingle;
public class DeviceConfigurationReplicationTest extends AbstractServerReplicationTest {
@Test
public void testEventReplication() throws InterruptedException {
public void testCreateConfiguration() throws InterruptedException {
DeviceConfigurationMatcher matcher = DeviceConfigurationMatcherAny.INSTANCE;
DeviceConfigurationImpl configuration = new DeviceConfigurationImpl();
master.createOrUpdateDeviceConfiguration(matcher, configuration);
master.createOrUpdateDeviceConfiguration(matcher, configuration);
Thread.sleep(1000);
Map<DeviceConfigurationMatcher, DeviceConfiguration> configurationMap = replica.getAllDeviceConfigurations();
assertEquals(1, configurationMap.size());
assertEquals(matcher.getMatcherType(), configurationMap.keySet().iterator().next().getMatcherType());
}
@Test
public void testUpdateConfiguration() throws InterruptedException {
DeviceConfigurationMatcher matcher = new DeviceConfigurationMatcherSingle("23");
DeviceConfigurationImpl configuration = new DeviceConfigurationImpl();
configuration.setMinimumRoundsForCourse(2);
master.createOrUpdateDeviceConfiguration(matcher, configuration);
configuration.setMinimumRoundsForCourse(42);
master.createOrUpdateDeviceConfiguration(matcher, configuration);
Thread.sleep(1000);
Map<DeviceConfigurationMatcher, DeviceConfiguration> configurationMap = replica.getAllDeviceConfigurations();
assertEquals(1, configurationMap.size());
assertEquals(configuration.getMinimumRoundsForCourse(), configurationMap.values().iterator().next().getMinimumRoundsForCourse());
}
@Test
public void testRemoveConfiguration() throws InterruptedException {
DeviceConfigurationMatcher matcher = new DeviceConfigurationMatcherSingle("24");
DeviceConfigurationImpl configuration = new DeviceConfigurationImpl();
master.createOrUpdateDeviceConfiguration(matcher, configuration);
Thread.sleep(1000);
master.removeDeviceConfiguration(matcher);
Thread.sleep(1000);
Map<DeviceConfigurationMatcher, DeviceConfiguration> configurationMap = replica.getAllDeviceConfigurations();
assertEquals(0, configurationMap.size());
}
}