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

true local replication test case that creates a leaderboard which is replicated automatically

Browse Source
This commit is contained in:
Axel Uhl
2012-05-03 00:26:01 +02:00
parent 9d74329444
commit 2f2901355c
14 changed files with 164 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/Activator.java
+1 -1
View File
@@ -20,7 +20,7 @@ public class Activator implements BundleActivator {
MessageBrokerConfiguration brokerConfig = new MessageBrokerConfiguration("SailingServerReplicationBroker",
"tcp://localhost:61616", new File(tmpDir, "kahadb").getAbsolutePath());
messageBrokerManager = new MessageBrokerManager(brokerConfig);
messageBrokerManager.startMessageBroker();
messageBrokerManager.startMessageBroker(true);
messageBrokerManager.createAndStartConnection();
replicationInstancesManager = new ReplicationInstancesManager();
ReplicationService serverReplicationMasterService = new ReplicationServiceImpl(replicationInstancesManager, messageBrokerManager);
java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/MessageBrokerManager.java
+2 -2
View File
@@ -24,13 +24,13 @@ public class MessageBrokerManager {
this.configuration = configuration;
}
public void startMessageBroker() throws Exception {
public void startMessageBroker(boolean useJmx) throws Exception {
broker = new BrokerService();
broker.setBrokerName(configuration.getBrokerName());
if (configuration.getDataStoreDirectory() != null) {
broker.setDataDirectory(configuration.getDataStoreDirectory());
}
broker.setUseJmx(true);
broker.setUseJmx(useJmx);
TransportConnector transportConnector = new TransportConnector();
transportConnector.setUri(new URI(configuration.getBrokerUrl()));
broker.addConnector(transportConnector);
java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/ReplicationServiceImpl.java
+7 -3
View File
@@ -174,7 +174,7 @@ public class ReplicationServiceImpl implements ReplicationService, OperationExec
}
/**
* @return the UUID that the master generated for this client which is alsy entered into {@link #replicaUUIDs}
* @return the UUID that the master generated for this client which is also entered into {@link #replicaUUIDs}
*/
private String registerReplicaWithMaster(ReplicationMasterDescriptor master) throws IOException, ClassNotFoundException {
URL replicationRegistrationRequestURL = master.getReplicationRegistrationRequestURL();
@@ -189,7 +189,7 @@ public class ReplicationServiceImpl implements ReplicationService, OperationExec
read = content.read(buf);
}
String replicaUUID = uuid.toString();
replicaUUIDs.put(master, replicaUUID);
registerReplicaUuidForMaster(replicaUUID, master);
return replicaUUID;
}
@@ -201,5 +201,9 @@ public class ReplicationServiceImpl implements ReplicationService, OperationExec
throw new RuntimeException(e);
}
}
protected void registerReplicaUuidForMaster(String uuid, ReplicationMasterDescriptor master) {
replicaUUIDs.put(master, uuid);
}
}