|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.body.http.HttpRemoteBodyImpl
An adapter for a LocalBody to be able to receive remote calls using HTTP. This helps isolate HTTP-specific code into a small set of specific classes.
Constructor Summary | |
HttpRemoteBodyImpl(UniqueID bodyID,
java.lang.String url,
java.lang.String jobID)
|
Method Summary | |
void |
clearHandlersLevel()
Clear the local map of handlers |
void |
disableAC()
Disables automatic continuation mechanism for this body |
void |
enableAC()
Enables automatic continuation mechanism for this body |
java.security.cert.X509Certificate |
getCertificate()
|
byte[] |
getCertificateEncoded()
|
java.util.ArrayList |
getEntities()
|
java.lang.String |
getHandlerizableInfo()
Get information about the handlerizable object |
java.util.HashMap |
getHandlersLevel()
Give a reference to a local map of handlers |
UniqueID |
getID()
Returns the UniqueID of this body This identifier is unique accross all JVMs |
java.lang.String |
getJobID()
|
java.lang.String |
getNodeURL()
Returns the url of the node this body is associated to The url of the node can change if the active object migrates |
SecurityContext |
getPolicy(SecurityContext securityContext)
|
Policy |
getPolicyFrom(java.security.cert.X509Certificate certificate)
|
Communication |
getPolicyTo(java.lang.String type,
java.lang.String from,
java.lang.String to)
|
ProActiveSecurityManager |
getProActiveSecurityManager()
|
java.security.PublicKey |
getPublicKey()
|
UniversalBody |
getRemoteAdapter()
Returns the remote friendly version of this body |
java.lang.String |
getVNName()
|
void |
initiateSession(int type,
UniversalBody body)
|
ConfidentialityTicket |
negociateKeyReceiverSide(ConfidentialityTicket confidentialityTicket,
long sessionID)
|
byte[][] |
publicKeyExchange(long sessionID,
UniversalBody distantBody,
byte[] my_pub,
byte[] my_cert,
byte[] sig_code)
|
byte[] |
randomValue(long sessionID,
byte[] cl_rand)
|
int |
receiveFTMessage(FTMessage ev)
For sending a non fonctional message to the FTManager linked to this object. |
int |
receiveReply(Reply reply)
Receives a reply in response to a former request. |
int |
receiveRequest(Request request)
Receives a request for later processing. |
byte[][] |
secretKeyExchange(long sessionID,
byte[] tmp,
byte[] tmp1,
byte[] tmp2,
byte[] tmp3,
byte[] tmp4)
|
void |
setExceptionHandler(java.lang.Class handler,
java.lang.Class exception)
|
void |
setExceptionHandler(Handler handler,
java.lang.Class exception)
Set a new handler within the table of the Handlerizable Object |
void |
setImmediateService(java.lang.String methodName)
For setting an immediate service for this body. |
long |
startNewSession(Communication policy)
|
void |
terminate()
Terminate the body. |
void |
terminateSession(long sessionID)
|
Handler |
unsetExceptionHandler(java.lang.Class exception)
Remove a handler from the table of the Handlerizable Object |
void |
updateLocation(UniqueID id,
UniversalBody body)
Signals to this body that the body identified by id is now to a new remote location. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public HttpRemoteBodyImpl(UniqueID bodyID, java.lang.String url, java.lang.String jobID)
bodyID
- url
- Method Detail |
public int receiveRequest(Request request) throws java.io.IOException, RenegotiateSessionException
UniversalBody
receiveRequest
in interface UniversalBody
request
- the request to process
java.io.IOException
- if the request cannot be accepted
RenegotiateSessionException
public int receiveReply(Reply reply) throws java.io.IOException
UniversalBody
receiveReply
in interface UniversalBody
reply
- the reply received
java.io.IOException
- if the reply cannot be acceptedpublic void terminate() throws java.io.IOException
UniversalBody
terminate
in interface UniversalBody
java.io.IOException
UniversalBody.terminate()
public java.lang.String getNodeURL()
UniversalBody
getNodeURL
in interface UniversalBody
public UniqueID getID()
UniversalBody
getID
in interface UniversalBody
public void updateLocation(UniqueID id, UniversalBody body) throws java.io.IOException
UniversalBody
updateLocation
in interface UniversalBody
id
- the id of the bodybody
- the stub to the new location
java.io.IOException
public void enableAC() throws java.io.IOException
UniversalBody
enableAC
in interface UniversalBody
java.io.IOException
public void disableAC() throws java.io.IOException
UniversalBody
disableAC
in interface UniversalBody
java.io.IOException
public void setImmediateService(java.lang.String methodName) throws java.io.IOException
UniversalBody
setImmediateService
in interface UniversalBody
java.io.IOException
public void initiateSession(int type, UniversalBody body) throws java.io.IOException, CommunicationForbiddenException, AuthenticationException, RenegotiateSessionException, SecurityNotAvailableException
initiateSession
in interface UniversalBody
java.io.IOException
CommunicationForbiddenException
AuthenticationException
RenegotiateSessionException
SecurityNotAvailableException
public void terminateSession(long sessionID) throws java.io.IOException, SecurityNotAvailableException
terminateSession
in interface UniversalBody
java.io.IOException
SecurityNotAvailableException
public java.security.cert.X509Certificate getCertificate() throws SecurityNotAvailableException, java.io.IOException
getCertificate
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public Policy getPolicyFrom(java.security.cert.X509Certificate certificate) throws SecurityNotAvailableException, java.io.IOException
getPolicyFrom
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public long startNewSession(Communication policy) throws SecurityNotAvailableException, java.io.IOException, RenegotiateSessionException
startNewSession
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
RenegotiateSessionException
public ConfidentialityTicket negociateKeyReceiverSide(ConfidentialityTicket confidentialityTicket, long sessionID) throws SecurityNotAvailableException, KeyExchangeException, java.io.IOException
negociateKeyReceiverSide
in interface UniversalBody
SecurityNotAvailableException
KeyExchangeException
java.io.IOException
public java.security.PublicKey getPublicKey() throws SecurityNotAvailableException, java.io.IOException
getPublicKey
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public byte[] randomValue(long sessionID, byte[] cl_rand) throws SecurityNotAvailableException, java.lang.Exception
randomValue
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
public byte[][] publicKeyExchange(long sessionID, UniversalBody distantBody, byte[] my_pub, byte[] my_cert, byte[] sig_code) throws SecurityNotAvailableException, java.lang.Exception
publicKeyExchange
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
public byte[][] secretKeyExchange(long sessionID, byte[] tmp, byte[] tmp1, byte[] tmp2, byte[] tmp3, byte[] tmp4) throws SecurityNotAvailableException, java.lang.Exception
secretKeyExchange
in interface UniversalBody
SecurityNotAvailableException
java.lang.Exception
public Communication getPolicyTo(java.lang.String type, java.lang.String from, java.lang.String to) throws SecurityNotAvailableException, java.io.IOException
getPolicyTo
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public SecurityContext getPolicy(SecurityContext securityContext) throws SecurityNotAvailableException, java.io.IOException
getPolicy
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.lang.String getVNName() throws SecurityNotAvailableException, java.io.IOException
getVNName
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public byte[] getCertificateEncoded() throws SecurityNotAvailableException, java.io.IOException
getCertificateEncoded
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.util.ArrayList getEntities() throws SecurityNotAvailableException, java.io.IOException
getEntities
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public ProActiveSecurityManager getProActiveSecurityManager() throws SecurityNotAvailableException, java.io.IOException
getProActiveSecurityManager
in interface UniversalBody
SecurityNotAvailableException
java.io.IOException
public java.util.HashMap getHandlersLevel() throws java.io.IOException
Handlerizable
getHandlersLevel
in interface Handlerizable
java.io.IOException
public void setExceptionHandler(java.lang.Class handler, java.lang.Class exception) throws java.io.IOException
java.io.IOException
public Handler unsetExceptionHandler(java.lang.Class exception) throws java.io.IOException
Handlerizable
unsetExceptionHandler
in interface Handlerizable
exception
- A class of non functional exception. It is a subclass of NonFunctionalException
.
java.io.IOException
public void setExceptionHandler(Handler handler, java.lang.Class exception) throws java.io.IOException
Handlerizable
setExceptionHandler
in interface Handlerizable
handler
- A handler associated with a class of non functional exception.exception
- A class of non functional exception. It is a subclass of NonFunctionalException
.
java.io.IOException
public java.lang.String getJobID()
getJobID
in interface Job
public void clearHandlersLevel() throws java.io.IOException
clearHandlersLevel
in interface Handlerizable
java.io.IOException
public java.lang.String getHandlerizableInfo() throws java.io.IOException
getHandlerizableInfo
in interface Handlerizable
java.io.IOException
public UniversalBody getRemoteAdapter()
UniversalBody
getRemoteAdapter
in interface UniversalBody
public int receiveFTMessage(FTMessage ev) throws java.io.IOException
UniversalBody
receiveFTMessage
in interface UniversalBody
ev
- the message to send
java.io.IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |