diff options
Diffstat (limited to 'runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageService.java')
-rw-r--r-- | runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageService.java | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageService.java b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageService.java index e7aa4be0e..a5f1a76ae 100644 --- a/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageService.java +++ b/runtime/org.eclipse.etrice.runtime.java/src/org/eclipse/etrice/runtime/java/messaging/MessageService.java @@ -15,14 +15,14 @@ package org.eclipse.etrice.runtime.java.messaging; /** - * The MessageService the backbone of the asynchronous communication inside a SubSystem + * The MessageService is the backbone of the asynchronous communication inside a SubSystem * It usually contains a thread a message queue and a dispatcher * * @author Thomas Schuetz (initial contribution) * @author Henrik Rentz-Reichert (extending RTObject, implementing Runnable) * */ -public class MessageService extends RTObject implements IMessageReceiver, Runnable { +public class MessageService extends RTObject implements IMessageService { private boolean running = false; @@ -34,11 +34,15 @@ public class MessageService extends RTObject implements IMessageReceiver, Runnab private Thread thread; private int priority; - public MessageService(IRTObject parent, int node, int thread, String name) { - this(parent, node, thread, name, Thread.NORM_PRIORITY); + public MessageService(IRTObject parent, ExecMode mode, int node, int thread, String name) { + this(parent, mode, 0, node, thread, name, Thread.NORM_PRIORITY); } - public MessageService(IRTObject parent, int node, int thread, String name, int priority) { + public MessageService(IRTObject parent, ExecMode mode, int nsec, int node, int thread, String name) { + this(parent, mode, nsec, node, thread, name, Thread.NORM_PRIORITY); + } + + public MessageService(IRTObject parent, ExecMode mode, int nsec, int node, int thread, String name, int priority) { super(parent, "MessageService_"+name); address = new Address(node, thread, 0); @@ -117,11 +121,8 @@ public class MessageService extends RTObject implements IMessageReceiver, Runnab } } - /** - * set the thread of this service - * (also sets the thread priority) - * - * @param thread + /* (non-Javadoc) + * @see org.eclipse.etrice.runtime.java.messaging.IMessageService#setThread(java.lang.Thread) */ public void setThread(Thread thread) { this.thread = thread; @@ -129,8 +130,8 @@ public class MessageService extends RTObject implements IMessageReceiver, Runnab thread.setPriority(priority); } - /** - * @return the thread of this service + /* (non-Javadoc) + * @see org.eclipse.etrice.runtime.java.messaging.IMessageService#getThread() */ public Thread getThread() { return thread; |