diff options
Diffstat (limited to 'sources/events/implementations/MessageReceiveEvent.java')
| -rw-r--r-- | sources/events/implementations/MessageReceiveEvent.java | 46 |
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); - } - - } -} |
