Interface MessageMediator

All Superinterfaces:
ResponseHandler
All Known Implementing Classes:
MessageMediatorImpl

public interface MessageMediator extends ResponseHandler
  • Method Details

    • getRequestIdFromRawBytes

      RequestId getRequestIdFromRawBytes()
    • setReplyHeader

      void setReplyHeader(LocateReplyOrReplyMessage header)
    • getLocateReplyHeader

      LocateReplyMessage getLocateReplyHeader()
    • getReplyHeader

      ReplyMessage getReplyHeader()
    • setReplyExceptionDetailMessage

      void setReplyExceptionDetailMessage(String message)
    • getRequestHeader

      RequestMessage getRequestHeader()
    • getGIOPVersion

      GIOPVersion getGIOPVersion()
    • getEncodingVersion

      byte getEncodingVersion()
    • getRequestId

      int getRequestId()
    • isOneWay

      boolean isOneWay()
    • getOperationName

      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

      Exception unmarshalDIIUserException(String repoId, InputStream inputStream)
    • setDIIException

      void setDIIException(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 interface ResponseHandler
      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 interface ResponseHandler
      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 a RequestDispatcher.
    • finishSendingRequest

      void finishSendingRequest()
      Used to send the message (or its last fragment). Note: this should be moved to a RequestDispatcher.
    • waitForResponse

      CDRInputObject waitForResponse()
    • setOutputObject

      void setOutputObject(CDROutputObject outputObject)
    • getOutputObject

      CDROutputObject getOutputObject()
    • setInputObject

      void setInputObject(CDRInputObject inputObject)
    • getInputObject

      CDRInputObject getInputObject()