eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-30 09:26:44 +00:00
Code Activity

use same message loader / persistence to avoid duplicate SailMasterConnector instances;

Browse Source 
in the long run, supporting equals on SwissTimingPersistenceImpl and the corresponding
configurations may help controlling the connector cache.
This commit is contained in:
Axel Uhl
2011-11-25 16:05:15 +01:00
parent 5f2ecd9584
commit eac6d6d1ad
11 changed files with 14 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.domain.swisstimingadapter.persistence/src/com/sap/sailing/domain/swisstimingadapter/persistence/StoreAndForward.java
+2 -2
View File
@@ -19,7 +19,6 @@ import com.sap.sailing.domain.swisstimingadapter.SailMasterTransceiver;
import com.sap.sailing.domain.swisstimingadapter.SwissTimingFactory;
import com.sap.sailing.domain.swisstimingadapter.persistence.impl.CollectionNames;
import com.sap.sailing.domain.swisstimingadapter.persistence.impl.FieldNames;
import com.sap.sailing.domain.swisstimingadapter.persistence.impl.SwissTimingAdapterPersistenceImpl;
import com.sap.sailing.mongodb.MongoDBConfiguration;
import com.sap.sailing.mongodb.MongoDBService;
import com.sap.sailing.util.Util.Pair;
@@ -182,6 +181,7 @@ public class StoreAndForward implements Runnable {
}
while (!stopped) {
Socket s = ss.accept();
logger.info("StoreAndForward received connector's connect request on port "+portForClients);
if (!stopped) {
synchronized (StoreAndForward.this) {
socketsToForwardTo.add(s);
@@ -246,7 +246,7 @@ public class StoreAndForward implements Runnable {
MongoDBService mongoDBService = MongoDBService.INSTANCE;
mongoDBService.setConfiguration(MongoDBConfiguration.getDefaultConfiguration());
SwissTimingAdapterPersistence swissTimingAdapterPersistence = new SwissTimingAdapterPersistenceImpl(mongoDBService, SwissTimingFactory.INSTANCE);
SwissTimingAdapterPersistence swissTimingAdapterPersistence = SwissTimingAdapterPersistence.INSTANCE;
new StoreAndForward(listenPort, clientPort, SwissTimingFactory.INSTANCE, swissTimingAdapterPersistence, mongoDBService);
}