Package com.sun.corba.ee.spi.protocol
Interface MessageMediator
-
- All Superinterfaces:
ResponseHandler
- All Known Implementing Classes:
MessageMediatorImpl
public interface MessageMediator extends ResponseHandler
-
-
Method Summary
-
-
-
Method Detail
-
getRequestIdFromRawBytes
RequestId getRequestIdFromRawBytes()
-
setReplyHeader
void setReplyHeader(LocateReplyOrReplyMessage header)
-
getLocateReplyHeader
LocateReplyMessage getLocateReplyHeader()
-
getReplyHeader
ReplyMessage getReplyHeader()
-
setReplyExceptionDetailMessage
void setReplyExceptionDetailMessage(java.lang.String message)
-
getRequestHeader
RequestMessage getRequestHeader()
-
getGIOPVersion
GIOPVersion getGIOPVersion()
-
getEncodingVersion
byte getEncodingVersion()
-
getRequestId
int getRequestId()
-
isOneWay
boolean isOneWay()
-
getOperationName
java.lang.String getOperationName()
-
getRequestServiceContexts
ServiceContexts getRequestServiceContexts()
-
setRequestServiceContexts
void setRequestServiceContexts(ServiceContexts sc)
-
getReplyServiceContexts
ServiceContexts getReplyServiceContexts()
-
getDispatchHeader
Message getDispatchHeader()
-
getThreadPoolToUse
int getThreadPoolToUse()
-
dispatch
boolean dispatch()
-
getStreamFormatVersion
byte getStreamFormatVersion()
-
getStreamFormatVersionForReply
byte getStreamFormatVersionForReply()
-
sendCancelRequestIfFinalFragmentNotSent
void sendCancelRequestIfFinalFragmentNotSent()
-
setDIIInfo
void setDIIInfo(Request request)
-
isDIIRequest
boolean isDIIRequest()
-
unmarshalDIIUserException
java.lang.Exception unmarshalDIIUserException(java.lang.String repoId, InputStream inputStream)
-
setDIIException
void setDIIException(java.lang.Exception exception)
-
handleDIIReply
void handleDIIReply(InputStream inputStream)
-
isSystemExceptionReply
boolean isSystemExceptionReply()
-
isUserExceptionReply
boolean isUserExceptionReply()
-
isLocationForwardReply
boolean isLocationForwardReply()
-
isDifferentAddrDispositionRequestedReply
boolean isDifferentAddrDispositionRequestedReply()
-
getAddrDispositionReply
short getAddrDispositionReply()
-
getForwardedIOR
IOR getForwardedIOR()
-
getSystemExceptionReply
SystemException getSystemExceptionReply()
-
cancelRequest
void cancelRequest()
-
getObjectKeyCacheEntry
ObjectKeyCacheEntry getObjectKeyCacheEntry()
-
getProtocolHandler
ProtocolHandler getProtocolHandler()
-
createReply
OutputStream createReply()
Description copied from interface:ResponseHandler
Called by the servant during a method invocation. The servant should call this method to create a reply marshal buffer if no exception occurred.- Specified by:
createReply
in interfaceResponseHandler
- Returns:
- an OutputStream suitable for marshalling the reply.
- See Also:
portable
package comments for unimplemented features
-
createExceptionReply
OutputStream createExceptionReply()
Description copied from interface:ResponseHandler
Called by the servant during a method invocation. The servant should call this method to create a reply marshal buffer if a user exception occurred.- Specified by:
createExceptionReply
in interfaceResponseHandler
- Returns:
- an OutputStream suitable for marshalling the exception ID and the user exception body.
-
executeReturnServantInResponseConstructor
boolean executeReturnServantInResponseConstructor()
-
setExecuteReturnServantInResponseConstructor
void setExecuteReturnServantInResponseConstructor(boolean b)
-
executeRemoveThreadInfoInResponseConstructor
boolean executeRemoveThreadInfoInResponseConstructor()
-
setExecuteRemoveThreadInfoInResponseConstructor
void setExecuteRemoveThreadInfoInResponseConstructor(boolean b)
-
executePIInResponseConstructor
boolean executePIInResponseConstructor()
-
setExecutePIInResponseConstructor
void setExecutePIInResponseConstructor(boolean b)
-
getBroker
ORB getBroker()
-
getContactInfo
ContactInfo getContactInfo()
-
getConnection
Connection getConnection()
-
initializeMessage
void initializeMessage()
Used to initialize message headers. Note: this should be moved to aRequestDispatcher
.
-
finishSendingRequest
void finishSendingRequest()
Used to send the message (or its last fragment). Note: this should be moved to aRequestDispatcher
.
-
waitForResponse
CDRInputObject waitForResponse()
-
setOutputObject
void setOutputObject(CDROutputObject outputObject)
-
getOutputObject
CDROutputObject getOutputObject()
-
setInputObject
void setInputObject(CDRInputObject inputObject)
-
getInputObject
CDRInputObject getInputObject()
-
-