|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.objectweb.proactive.core.body.message.MessageImpl | +--org.objectweb.proactive.core.body.request.RequestImpl
Field Summary | |
protected java.lang.String |
codebase
|
static org.apache.log4j.Logger |
logger
|
protected MethodCall |
methodCall
|
protected int |
sendCounter
Indicates if the method has been sent through a forwarder |
protected UniversalBody |
sender
transient because we deal with the serialization of this variable in a custom manner. see writeObject method |
long |
sessionID
|
Fields inherited from class org.objectweb.proactive.core.body.message.MessageImpl |
ciphered, isOneWay, methodName, sequenceNumber, sourceID, timeStamp |
Constructor Summary | |
RequestImpl(MethodCall methodCall,
UniversalBody sender,
boolean isOneWay,
long nextSequenceID)
|
Method Summary | |
protected Reply |
createReply(Body targetBody,
java.lang.Object result)
|
boolean |
decrypt(ProActiveSecurityManager psm)
|
MethodCall |
getMethodCall()
Returns the MethodCall embedded in the request |
java.lang.Object |
getParameter(int index)
Returns the parameter number index from the method call
embedded in the request |
UniversalBody |
getSender()
Returns the sender of this request |
long |
getSessionId()
|
boolean |
hasBeenForwarded()
Returns true if the request has been forwarded |
boolean |
isCiphered()
|
void |
notifyReception(UniversalBody bodyReceiver)
Notifies the request that it has been received by the destination. |
void |
send(UniversalBody destinationBody)
Sends this request to the body destination |
protected void |
sendRequest(UniversalBody destinationBody)
|
Reply |
serve(Body targetBody)
Serves this request by executing the embedded method call using the given targetBody . |
protected java.lang.Object |
serveInternal(Body targetBody)
|
Methods inherited from class org.objectweb.proactive.core.body.message.MessageImpl |
getMethodName, getSequenceNumber, getSourceBodyID, getTimeStamp, isOneWay, toString |
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.message.Message |
getMethodName, getSequenceNumber, getSourceBodyID, getTimeStamp, isOneWay |
Field Detail |
public static org.apache.log4j.Logger logger
protected MethodCall methodCall
protected int sendCounter
protected transient UniversalBody sender
public long sessionID
protected java.lang.String codebase
Constructor Detail |
public RequestImpl(MethodCall methodCall, UniversalBody sender, boolean isOneWay, long nextSequenceID)
Method Detail |
public void send(UniversalBody destinationBody) throws java.io.IOException, RenegotiateSessionException
Request
send
in interface Request
destinationBody
- the body destination of this request
java.io.IOException
- if the request fails to be sent
RenegotiateSessionException
public UniversalBody getSender()
Request
getSender
in interface Request
public Reply serve(Body targetBody) throws ServeException
Request
targetBody
. Once the eventual result obtained from the method call
a the reply is returned (based on that result).
serve
in interface Request
targetBody
- the body destination of the call
ServeException
- if the method call fails to be servedpublic boolean hasBeenForwarded()
Request
hasBeenForwarded
in interface Request
public java.lang.Object getParameter(int index)
Request
index
from the method call
embedded in the request
getParameter
in interface Request
index
- the position of the parameter to return.
public MethodCall getMethodCall()
Request
getMethodCall
in interface Request
public void notifyReception(UniversalBody bodyReceiver) throws java.io.IOException
Request
notifyReception
in interface Request
bodyReceiver
- the body destination that received the request
java.io.IOException
- if the request failed to perform a possible
operation upon that notificationprotected java.lang.Object serveInternal(Body targetBody) throws ServeException
ServeException
protected Reply createReply(Body targetBody, java.lang.Object result)
protected void sendRequest(UniversalBody destinationBody) throws java.io.IOException, RenegotiateSessionException
java.io.IOException
RenegotiateSessionException
public boolean isCiphered()
isCiphered
in interface Request
public boolean decrypt(ProActiveSecurityManager psm) throws RenegotiateSessionException
decrypt
in interface Request
RenegotiateSessionException
public long getSessionId()
getSessionId
in interface Request
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |