Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageDispatcher.java')
-rw-r--r--runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageDispatcher.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageDispatcher.java b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageDispatcher.java
index ab3ec7c26..5ba4115cf 100644
--- a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageDispatcher.java
+++ b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageDispatcher.java
@@ -38,7 +38,7 @@ public class MessageDispatcher extends RTObject implements IMessageReceiver {
node_map.put(receiver.getAddress().objectID, receiver);
}
else if(receiver.getAddress().threadID != address.threadID){
- thread_map.put(receiver.getAddress().objectID, receiver);
+ thread_map.put(receiver.getAddress().threadID, receiver);
}
else {
local_map.put(receiver.getAddress().objectID, receiver);
@@ -53,7 +53,7 @@ public class MessageDispatcher extends RTObject implements IMessageReceiver {
receiver = node_map.get(msg.getAddress().objectID);
}
else if(msg.getAddress().threadID != address.threadID){
- receiver = thread_map.get(msg.getAddress().objectID);
+ receiver = thread_map.get(msg.getAddress().threadID);
}
else {
// Same node, same thread -> local call Dispatch Map

Back to the top