diff options
Diffstat (limited to 'runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/ActorClassBase.java')
| -rw-r--r-- | runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/ActorClassBase.java | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/ActorClassBase.java b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/ActorClassBase.java index de874bd1a..57a8eb84a 100644 --- a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/ActorClassBase.java +++ b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/modelbase/ActorClassBase.java @@ -13,6 +13,7 @@ import org.eclipse.etrice.runtime.java.messaging.IMessageReceiver; import org.eclipse.etrice.runtime.java.messaging.IRTObject;
import org.eclipse.etrice.runtime.java.messaging.Message;
import org.eclipse.etrice.runtime.java.messaging.MessageService;
+import org.eclipse.etrice.runtime.java.messaging.RTServices;
/**
* The base class for model actor classes.
@@ -36,13 +37,14 @@ public abstract class ActorClassBase extends EventReceiver implements IMessageRe */
protected int state;
- private MessageService msgsvc = null;
+ private MessageService ownMsgsvc = null;
+ private Address ownAddr = null;
- public ActorClassBase(IRTObject parent, String name, IMessageReceiver msgsvc) {
+ public ActorClassBase(IRTObject parent, String name, Address ownAddr) {
super(parent, name);
- if (msgsvc instanceof MessageService)
- this.msgsvc = (MessageService) msgsvc;
+ this.ownAddr = ownAddr;
+ ownMsgsvc = RTServices.getInstance().getMsgSvcCtrl().getMsgSvc(this.ownAddr.threadID);
}
public String toString(){
@@ -77,6 +79,6 @@ public abstract class ActorClassBase extends EventReceiver implements IMessageRe }
public MessageService getMsgsvc() {
- return msgsvc;
+ return ownMsgsvc;
}
}
|