fixed SwissTiming tests

This commit is contained in:
Axel Uhl
2011-11-14 09:14:27 +01:00
parent 6430364b1e
commit 04f1ae19df
3 changed files with 11 additions and 6 deletions
@@ -43,5 +43,7 @@ public interface SwissTimingAdapterPersistence extends RaceSpecificMessageLoader
void storeSailMasterMessage(SailMasterMessage message);
void storeRace(Race race);
void dropAllRaceMasterData();
}
@@ -232,6 +232,10 @@ public class SwissTimingAdapterPersistenceImpl implements SwissTimingAdapterPers
result.put(FieldNames.RACE_STARTTIME.name(), race.getStartTime() == null ? null : new Long(race.getStartTime().asMillis()));
racesCollection.update(query, result, /* upsrt */ true, /* multi */ false);
}
@Override
public void dropAllRaceMasterData() {
DBCollection racesCollection = database.getCollection(CollectionNames.RACES_MASTERDATA.name());
racesCollection.drop();
}
}
@@ -49,14 +49,13 @@ public class SailMasterConnectivityTest {
public void setUp() throws InterruptedException, ParseException {
startSailMasterDummy();
SwissTimingAdapterPersistence swissTimingPersistence = SwissTimingAdapterPersistence.INSTANCE;
Race raceW4702 = new RaceImpl("W4702", "W4702");
Race race4711 = new RaceImpl("4711", "4711");
Race race4712 = new RaceImpl("4712", "4712");
swissTimingPersistence.storeRace(raceW4702);
swissTimingPersistence.dropAllRaceMasterData();
Race race4711 = new RaceImpl("4711", "A wonderful test race");
Race race4712 = new RaceImpl("4712", "Not such a wonderful race");
swissTimingPersistence.storeRace(race4711);
swissTimingPersistence.storeRace(race4712);
connector = SwissTimingFactory.INSTANCE.getOrCreateSailMasterConnector("localhost", port, swissTimingPersistence);
connector.trackRace(raceW4702.getRaceID());
connector.trackRace("W4702");
connector.trackRace(race4711.getRaceID());
connector.trackRace(race4712.getRaceID());
}