VSMessage constructor does not requier the protocol's classname anymore.

7 files changed, 14 insertions, 14 deletions

diff --git a/sources/protocols/implementations/BerkelyTimeProtocol.java b/sources/protocols/implementations/BerkelyTimeProtocol.java
index 176b2d7..d1a403f 100644
--- a/sources/protocols/implementations/BerkelyTimeProtocol.java
+++ b/sources/protocols/implementations/BerkelyTimeProtocol.java
@@ -70,7 +70,7 @@ public class BerkelyTimeProtocol extends VSProtocol {
         peers = new ArrayList<Integer>();
         peers.addAll(getVector("processPIDs"));
         requestTime = process.getTime();
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("isRequest", true);
         sendMessage(message);
     }
@@ -136,7 +136,7 @@ public class BerkelyTimeProtocol extends VSProtocol {
         for (Integer processID : processTimes.keySet()) {
             long realProcessTime = realTimesRTT.get(processID).longValue();
             long diff = avgTime - realProcessTime;
-            VSMessage message = new VSMessage(getClassname());
+            VSMessage message = new VSMessage();
             message.setBoolean("isJustify", true);
             message.setLong("timeDiff", diff);
             message.setInteger("receiverProcessID", processID);
@@ -155,7 +155,7 @@ public class BerkelyTimeProtocol extends VSProtocol {
      */
     protected void onServerRecv(VSMessage recvMessage) {
         if (recvMessage.getBoolean("isRequest")) {
-            VSMessage message = new VSMessage(getClassname());
+            VSMessage message = new VSMessage();
             message.setInteger("processID", process.getProcessID());
             message.setLong("time", process.getTime());
             message.setBoolean("isResponse", true);
diff --git a/sources/protocols/implementations/BroadcastSturmProtocol.java b/sources/protocols/implementations/BroadcastSturmProtocol.java
index be4b0ba..fafc732 100644
--- a/sources/protocols/implementations/BroadcastSturmProtocol.java
+++ b/sources/protocols/implementations/BroadcastSturmProtocol.java
@@ -46,7 +46,7 @@ public class BroadcastSturmProtocol extends VSProtocol {
      * @see protocols.VSProtocol#onClientStart()
      */
     protected void onClientStart() {
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setInteger("Broadcast", broadcastCount++);
         sentMessages.add(message);
         sendMessage(message);
@@ -70,7 +70,7 @@ public class BroadcastSturmProtocol extends VSProtocol {
      */
     protected void onServerRecv(VSMessage recvMessage) {
         if (!sentMessages.contains(recvMessage)) {
-            VSMessage message = new VSMessage(getClassname());
+            VSMessage message = new VSMessage();
             message.setInteger("Broadcast", recvMessage.getInteger("Broadcast"));
 
             sentMessages.add(message);
diff --git a/sources/protocols/implementations/DummyProtocol.java b/sources/protocols/implementations/DummyProtocol.java
index 1b3d3e5..1a409da 100644
--- a/sources/protocols/implementations/DummyProtocol.java
+++ b/sources/protocols/implementations/DummyProtocol.java
@@ -40,7 +40,7 @@ public class DummyProtocol extends VSProtocol {
     protected void onClientStart() {
         logg("onClientStart()");
 
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setString("Greeting", "Hello World!");
         message.setInteger("A number", 1);
         message.setBoolean("A boolean", true);
diff --git a/sources/protocols/implementations/ExternalTimeSyncProtocol.java b/sources/protocols/implementations/ExternalTimeSyncProtocol.java
index a3fb2ba..e9e96a2 100644
--- a/sources/protocols/implementations/ExternalTimeSyncProtocol.java
+++ b/sources/protocols/implementations/ExternalTimeSyncProtocol.java
@@ -47,7 +47,7 @@ public class ExternalTimeSyncProtocol extends VSProtocol {
         waitingForResponse = true;
 
         /* Multicast message to all processes */
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("isClientRequest", true);
         sendMessage(message);
     }
@@ -87,7 +87,7 @@ public class ExternalTimeSyncProtocol extends VSProtocol {
             return;
 
         /* Multicast message to all processes */
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setLong("time", process.getTime());
         message.setBoolean("isServerResponse", true);
         sendMessage(message);
diff --git a/sources/protocols/implementations/InternalTimeSyncProtocol.java b/sources/protocols/implementations/InternalTimeSyncProtocol.java
index 2e1c013..0b784a1 100644
--- a/sources/protocols/implementations/InternalTimeSyncProtocol.java
+++ b/sources/protocols/implementations/InternalTimeSyncProtocol.java
@@ -47,7 +47,7 @@ public class InternalTimeSyncProtocol extends VSProtocol {
         waitingForResponse = true;
 
         /* Multicast message to all processes */
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("isClientRequest", true);
         sendMessage(message);
     }
@@ -92,7 +92,7 @@ public class InternalTimeSyncProtocol extends VSProtocol {
             return;
 
         /* Multicast message to all processes */
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setLong("time", process.getTime());
         message.setBoolean("isServerResponse", true);
         sendMessage(message);
diff --git a/sources/protocols/implementations/OnePhaseCommitProtocol.java b/sources/protocols/implementations/OnePhaseCommitProtocol.java
index cb984d3..30c12f1 100644
--- a/sources/protocols/implementations/OnePhaseCommitProtocol.java
+++ b/sources/protocols/implementations/OnePhaseCommitProtocol.java
@@ -52,7 +52,7 @@ public class OnePhaseCommitProtocol extends VSProtocol {
      */
     protected void onClientStart() {
         int numProcesses = getInteger("numProcesses");
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("wantAck", true);
         sendMessage(message);
     }
diff --git a/sources/protocols/implementations/PingPongProtocol.java b/sources/protocols/implementations/PingPongProtocol.java
index 0058934..543b8df 100644
--- a/sources/protocols/implementations/PingPongProtocol.java
+++ b/sources/protocols/implementations/PingPongProtocol.java
@@ -44,7 +44,7 @@ public class PingPongProtocol extends VSProtocol {
      * @see protocols.VSProtocol#onClientStart()
      */
     protected void onClientStart() {
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("fromClient", true);
         message.setInteger("counter", ++clientCounter);
         sendMessage(message);
@@ -59,7 +59,7 @@ public class PingPongProtocol extends VSProtocol {
 
         logg("message: " + recvMessage.getInteger("counter"));
 
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("fromClient", true);
         message.setInteger("counter", ++clientCounter);
         sendMessage(message);
@@ -81,7 +81,7 @@ public class PingPongProtocol extends VSProtocol {
 
         logg("message: " + recvMessage.getInteger("counter"));
 
-        VSMessage message = new VSMessage(getClassname());
+        VSMessage message = new VSMessage();
         message.setBoolean("fromServer", true);
         message.setInteger("counter", ++serverCounter);
         sendMessage(message);