summaryrefslogtreecommitdiff
path: root/sources/events/implementations/MessageReceiveEvent.java
diff options
context:
space:
mode:
Diffstat (limited to 'sources/events/implementations/MessageReceiveEvent.java')
-rw-r--r--sources/events/implementations/MessageReceiveEvent.java46
1 files changed, 0 insertions, 46 deletions
diff --git a/sources/events/implementations/MessageReceiveEvent.java b/sources/events/implementations/MessageReceiveEvent.java
deleted file mode 100644
index d5c1416..0000000
--- a/sources/events/implementations/MessageReceiveEvent.java
+++ /dev/null
@@ -1,46 +0,0 @@
-package events.implementations;
-
-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);
- }
-
- }
-}