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, Handlerizable, 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, clearHandlersLevel, disableAC, enableAC, enterInThreadStore, exitFromThreadStore, getCertificate, getCertificateEncoded, getEntities, getFuturePool, getHandlerizableInfo, getHandlersLevel, getName, getPolicy, getPolicyFrom, getPolicyTo, getProActiveSecurityManager, getPublicKey, getReifiedObject, getRequestQueue, getSPMDGroup, getSPMDGroupSize, getVNName, initiateSession, isActive, isAlive, negociateKeyReceiverSide, publicKeyExchange, randomValue, receiveReply, receiveRequest, renegociateSessionIfNeeded, secretKeyExchange, sendRequest, sendSPMDGroupCall, serve, setExceptionHandler, setLocalBodyImpl, setPolicyServer, setSPMDGroup, startDefaultProActiveSecurityManager, startNewSession, terminate, terminateSession, toString, unsetExceptionHandler |
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()
- Specified by:
getJobID
in interface Job
- Overrides:
getJobID
in class AbstractUniversalBody
- See Also:
Job.getJobID()
Copyright ? October 2004 INRIA All Rights Reserved.