org.objectweb.proactive.core.body
Class HalfBody
java.lang.Object
|
+--org.objectweb.proactive.core.body.AbstractUniversalBody
|
+--org.objectweb.proactive.core.body.AbstractBody
|
+--org.objectweb.proactive.core.body.HalfBody
- All Implemented Interfaces:
- Body, Job, LocalBodyStrategy, MessageEventProducer, java.io.Serializable, UniversalBody
- public class HalfBody
- extends AbstractBody
- See Also:
- Serialized Form
Methods inherited from class org.objectweb.proactive.core.body.AbstractBody |
acceptCommunication, activityStarted, activityStopped, blockCommunication, checkNewLocation, disableAC, enableAC, enterInThreadStore, exitFromThreadStore, getCertificate, getCertificateEncoded, getEntities, getFuturePool, getName, getPolicy, getPolicyFrom, getPolicyTo, getProActiveSecurityManager, getPublicKey, getReifiedObject, getRequestQueue, getSPMDGroup, getVNName, initiateSession, isActive, isAlive, negociateKeyReceiverSide, publicKeyExchange, randomValue, receiveReply, receiveRequest, renegociateSessionIfNeeded, secretKeyExchange, sendRequest, serve, setLocalBodyImpl, setSPMDGroup, startDefaultProActiveSecurityManager, startNewSession, terminate, terminateSession, test, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
getHalfBody
public static HalfBody getHalfBody(MetaObjectFactory factory)
addMessageEventListener
public void addMessageEventListener(MessageEventListener listener)
- Description copied from interface:
MessageEventProducer
- Adds a listener of MessageEvent to this body. The listener will receive event
for all messages sent or received
- Parameters:
listener
- the listener to add
removeMessageEventListener
public void removeMessageEventListener(MessageEventListener listener)
- Description copied from interface:
MessageEventProducer
- Removes the MessageEventListener from this body.
- Parameters:
listener
- the listener to remove
internalReceiveRequest
protected void internalReceiveRequest(Request request)
throws java.io.IOException
- Receives a request for later processing. The call to this method is non blocking
unless the body cannot temporary receive the request.
- Specified by:
internalReceiveRequest
in class AbstractBody
- Parameters:
request
- the request to process
- Throws:
java.io.IOException
- if the request cannot be accepted
internalReceiveReply
protected void internalReceiveReply(Reply reply)
throws java.io.IOException
- Receives a reply in response to a former request.
- Specified by:
internalReceiveReply
in class AbstractBody
- Parameters:
reply
- the reply received
- Throws:
java.io.IOException
- if the reply cannot be accepted
setImmediateService
public void setImmediateService(java.lang.String methodName)
- Description copied from interface:
UniversalBody
- For setting an immediate service for this body.
An immediate service is a method that will bw excecuted by the calling thread.
getJobID
public java.lang.String getJobID()
- Returns:
- the jobID associated with this object
- See Also:
Job.getJobID()
Copyright © April 2004 INRIA All Rights Reserved.