A new package events.internal has been introduced. It only contains events which are for internal usage. the events which are in the events.implementations menu are the events which are editable in the task manager.

1 files changed, 46 insertions, 0 deletions

diff --git a/sources/events/internal/MessageReceiveEvent.java b/sources/events/internal/MessageReceiveEvent.java
new file mode 100644
index 0000000..d499899
--- /dev/null
+++ b/sources/events/internal/MessageReceiveEvent.java
@@ -0,0 +1,46 @@
+package events.internal;
+
+import core.VSMessage;
+import core.VSProcess;
+import events.VSEvent;
+import protocols.VSProtocol;
+
+public class MessageReceiveEvent extends VSEvent {
+    private VSMessage message;
+
+    public MessageReceiveEvent(VSMessage message) {
+        this.message = message;
+    }
+
+    protected void onInit() {
+        setClassname(getClass().toString());
+    }
+
+    public void onStart() {
+        String eventName = message.getName();
+        String protocolClassname = message.getProtocolClassname();
+
+        process.updateLamportTime(message.getLamportTime()+1);
+        process.updateVectorTime(message.getVectorTime());
+
+        Object protocolObj = null;
+
+        if (process.objectExists(protocolClassname))
+            protocolObj = process.getObject(protocolClassname);
+
+        StringBuffer buffer = new StringBuffer();
+        buffer.append(prefs.getString("lang.message.recv"));
+        buffer.append("; ");
+        buffer.append(message);;
+
+        if (protocolObj == null) {
+            logg(buffer.toString());
+
+        } else {
+            final VSProtocol protocol = (VSProtocol) protocolObj;
+            logg(buffer.toString());
+            protocol.onMessageRecv(message);
+        }
+
+    }
+}