Package com.sun.corba.ee.spi.protocol
Interface MessageMediator
- All Superinterfaces:
ResponseHandler
- All Known Implementing Classes:
MessageMediatorImpl
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Called by the servant during a method invocation.Called by the servant during a method invocation.boolean
dispatch()
boolean
boolean
boolean
void
Used to send the message (or its last fragment).short
byte
int
byte
byte
int
void
handleDIIReply
(InputStream inputStream) void
Used to initialize message headers.boolean
boolean
boolean
boolean
isOneWay()
boolean
boolean
void
void
setDIIException
(Exception exception) void
setDIIInfo
(Request request) void
setExecutePIInResponseConstructor
(boolean b) void
void
setExecuteReturnServantInResponseConstructor
(boolean b) void
setInputObject
(CDRInputObject inputObject) void
setOutputObject
(CDROutputObject outputObject) void
setReplyExceptionDetailMessage
(String message) void
void
unmarshalDIIUserException
(String repoId, InputStream inputStream)
-
Method Details
-
getRequestIdFromRawBytes
RequestId getRequestIdFromRawBytes() -
setReplyHeader
-
getLocateReplyHeader
LocateReplyMessage getLocateReplyHeader() -
getReplyHeader
ReplyMessage getReplyHeader() -
setReplyExceptionDetailMessage
-
getRequestHeader
RequestMessage getRequestHeader() -
getGIOPVersion
GIOPVersion getGIOPVersion() -
getEncodingVersion
byte getEncodingVersion() -
getRequestId
int getRequestId() -
isOneWay
boolean isOneWay() -
getOperationName
String getOperationName() -
getRequestServiceContexts
ServiceContexts getRequestServiceContexts() -
setRequestServiceContexts
-
getReplyServiceContexts
ServiceContexts getReplyServiceContexts() -
getDispatchHeader
Message getDispatchHeader() -
getThreadPoolToUse
int getThreadPoolToUse() -
dispatch
boolean dispatch() -
getStreamFormatVersion
byte getStreamFormatVersion() -
getStreamFormatVersionForReply
byte getStreamFormatVersionForReply() -
sendCancelRequestIfFinalFragmentNotSent
void sendCancelRequestIfFinalFragmentNotSent() -
setDIIInfo
-
isDIIRequest
boolean isDIIRequest() -
unmarshalDIIUserException
-
setDIIException
-
handleDIIReply
-
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:
-
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
-
getOutputObject
CDROutputObject getOutputObject() -
setInputObject
-
getInputObject
CDRInputObject getInputObject()
-