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

Field Summary
 
Fields inherited from class org.objectweb.proactive.core.body.AbstractBody
internalBodySecurity, isSecurityOn, localBodyStrategy, logger, openedSessions, pgm, psm, threadStore
 
Fields inherited from class org.objectweb.proactive.core.body.AbstractUniversalBody
bodyID, location, nodeURL, remoteBody, remoteBodyFactory
 
Method Summary
 void addMessageEventListener(MessageEventListener listener)
          Adds a listener of MessageEvent to this body.
static HalfBody getHalfBody(MetaObjectFactory factory)
           
 java.lang.String getJobID()
           
protected  void internalReceiveReply(Reply reply)
          Receives a reply in response to a former request.
protected  void internalReceiveRequest(Request request)
          Receives a request for later processing.
 void removeMessageEventListener(MessageEventListener listener)
          Removes the MessageEventListener from this body.
 void setImmediateService(java.lang.String methodName)
          For setting an immediate service for this body.
 
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 org.objectweb.proactive.core.body.AbstractUniversalBody
getID, getNodeURL, getRemoteAdapter, updateLocation
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.objectweb.proactive.core.body.UniversalBody
getID, getNodeURL, getRemoteAdapter, updateLocation
 

Method Detail

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.