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()
      /////////////////////////////////////////////////
      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()