CorbaMessageMediatorImpl (Red Hat JBoss Enterprise Application Platform 7.2.0.Beta public API)

java.lang.Object
- com.sun.corba.se.impl.protocol.CorbaMessageMediatorImpl

All Implemented Interfaces:

MessageHandler, MessageMediator, ProtocolHandler, CorbaMessageMediator, CorbaProtocolHandler, ResponseHandler
```
public class CorbaMessageMediatorImpl
extends Object
implements CorbaMessageMediator, CorbaProtocolHandler, MessageHandler
```
Author:

Harold Carr

Field Summary

Fields
Modifier and Type	Field and Description
`protected boolean`	`_executePIInResponseConstructor`
`protected boolean`	`_executeRemoveThreadInfoInResponseConstructor`
`protected boolean`	`_executeReturnServantInResponseConstructor`
`protected short`	`addrDisposition`
`protected boolean`	`cancelRequestAlreadySent`
`protected CorbaConnection`	`connection`
`protected CorbaContactInfo`	`contactInfo`
`protected Request`	`diiRequest`
`protected ByteBuffer`	`dispatchByteBuffer`
`protected Message`	`dispatchHeader`
`protected CDRInputObject`	`inputObject`
`protected InterceptorsSystemException`	`interceptorWrapper`
`protected boolean`	`isThreadDone`
`protected Message`	`messageHeader`
`protected ORB`	`orb`
`protected CDROutputObject`	`outputObject`
`protected ProtocolHandler`	`protocolHandler`
`protected String`	`replyExceptionDetailMessage`
`protected LocateReplyOrReplyMessage`	`replyHeader`
`protected IOR`	`replyIOR`
`protected RequestMessage`	`requestHeader`
`protected Integer`	`requestIdInteger`
`protected byte`	`streamFormatVersion`
`protected boolean`	`streamFormatVersionSet`
`protected ORBUtilSystemException`	`wrapper`

Constructor Summary

Constructors
Constructor and Description
`CorbaMessageMediatorImpl(ORB orb, Connection connection)`
`CorbaMessageMediatorImpl(ORB orb, ContactInfo contactInfo, Connection connection, GIOPVersion giopVersion, IOR ior, int requestId, short addrDisposition, String operationName, boolean isOneWay)`
`CorbaMessageMediatorImpl(ORB orb, CorbaConnection connection, Message dispatchHeader, ByteBuffer byteBuffer)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`protected SystemException`	`convertThrowableToSystemException(Throwable throwable, CompletionStatus completionStatus)`
`OutputStream`	`createExceptionReply()` Called by the servant during a method invocation.
`CorbaMessageMediator`	`createLocationForward(CorbaMessageMediator messageMediator, IOR ior, ServiceContexts svc)`
`OutputStream`	`createReply()` Called by the servant during a method invocation.
`CorbaMessageMediator`	`createResponse(CorbaMessageMediator messageMediator, ServiceContexts svc)`
`protected CorbaMessageMediator`	`createResponseHelper(CorbaMessageMediator messageMediator, ReplyMessage reply, IOR ior)`
`protected CorbaMessageMediator`	`createResponseHelper(CorbaMessageMediator messageMediator, ServiceContexts svc)`
`protected CorbaMessageMediator`	`createResponseHelper(CorbaMessageMediator messageMediator, ServiceContexts svc, boolean user)`
`CorbaMessageMediator`	`createSystemExceptionResponse(CorbaMessageMediator messageMediator, SystemException ex, ServiceContexts svc)`
`CorbaMessageMediator`	`createUnknownExceptionResponse(CorbaMessageMediator messageMediator, UnknownException ex)`
`CorbaMessageMediator`	`createUserExceptionResponse(CorbaMessageMediator messageMediator, ServiceContexts svc)`
`boolean`	`executePIInResponseConstructor()`
`boolean`	`executeRemoveThreadInfoInResponseConstructor()`
`boolean`	`executeReturnServantInResponseConstructor()`
`void`	`finishSendingRequest()` Used to send the message (or its last fragment).
`short`	`getAddrDisposition()`
`short`	`getAddrDispositionReply()`
`Broker`	`getBroker()` The `Broker` associated with an invocation.
`Connection`	`getConnection()` Get the `Connection` on which this message is sent or received.
`ContactInfo`	`getContactInfo()` Get the `ContactInfo` which created this `MessageMediator`.
`ByteBuffer`	`getDispatchBuffer()`
`Message`	`getDispatchHeader()`
`byte`	`getEncodingVersion()`
`IOR`	`getForwardedIOR()`
`GIOPVersion`	`getGIOPVersion()`
`InputObject`	`getInputObject()` Used to get the `InputObject` used for the message.
`LocateReplyMessage`	`getLocateReplyHeader()`
`ObjectKey`	`getObjectKey()`
`String`	`getOperationName()`
`OutputObject`	`getOutputObject()` Used to get the `OutputObject` used for the message.
`CorbaProtocolHandler`	`getProtocolHandler()`
`ReplyMessage`	`getReplyHeader()`
`ServiceContexts`	`getReplyServiceContexts()`
`RequestMessage`	`getRequestHeader()`
`int`	`getRequestId()`
`Integer`	`getRequestIdInteger()`
`ServiceContexts`	`getRequestServiceContexts()`
`protected ServiceContexts`	`getServiceContextsForReply(CorbaMessageMediator messageMediator, ServiceContexts contexts)`
`byte`	`getStreamFormatVersion()`
`byte`	`getStreamFormatVersionForReply()` If the RMI-IIOP maximum stream format version service context is present, it indicates the maximum stream format version we could use for the reply.
`SystemException`	`getSystemExceptionReply()`
`int`	`getThreadPoolToUse()`
`protected void`	`handleAddressingDisposition(CorbaMessageMediator messageMediator, AddressingDispositionException ex)`
`void`	`handleDIIReply(InputStream inputStream)`
`void`	`handleInput(CancelRequestMessage header)`
`void`	`handleInput(FragmentMessage_1_1 header)`
`void`	`handleInput(FragmentMessage_1_2 header)`
`void`	`handleInput(LocateReplyMessage_1_0 header)`
`void`	`handleInput(LocateReplyMessage_1_1 header)`
`void`	`handleInput(LocateReplyMessage_1_2 header)`
`void`	`handleInput(LocateRequestMessage_1_0 header)`
`void`	`handleInput(LocateRequestMessage_1_1 header)`
`void`	`handleInput(LocateRequestMessage_1_2 header)`
`void`	`handleInput(Message header)` Used for message types for which we don't have concrete classes, yet, such as CloseConnection and MessageError, as well as unknown types.
`void`	`handleInput(ReplyMessage_1_0 header)`
`void`	`handleInput(ReplyMessage_1_1 header)`
`void`	`handleInput(ReplyMessage_1_2 header)`
`void`	`handleInput(RequestMessage_1_0 header)`
`void`	`handleInput(RequestMessage_1_1 header)`
`void`	`handleInput(RequestMessage_1_2 header)`
`protected void`	`handleLocateRequest(CorbaMessageMediator messageMediator)`
`void`	`handleRequest(LocateRequestMessage msg, CorbaMessageMediator messageMediator)`
`boolean`	`handleRequest(MessageMediator messageMediator)` This method determines the type of an incoming message and dispatches it appropriately.
`void`	`handleRequest(RequestMessage msg, CorbaMessageMediator messageMediator)`
`protected void`	`handleRequestRequest(CorbaMessageMediator messageMediator)`
`void`	`handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus)`
`protected void`	`handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus, int iteration)`
`void`	`initializeMessage()` Used to initialize message headers.
`boolean`	`isDifferentAddrDispositionRequestedReply()`
`boolean`	`isDIIRequest()`
`boolean`	`isLocationForwardReply()`
`boolean`	`isOneWay()`
`boolean`	`isSystemExceptionReply()`
`boolean`	`isUserExceptionReply()`
`protected String`	`opAndId(CorbaMessageMediator mediator)`
`protected void`	`runInterceptors(CorbaMessageMediator messageMediator, ReplyMessage reply)`
`protected void`	`runRemoveThreadInfo(CorbaMessageMediator messageMediator)`
`protected void`	`runServantPostInvoke(CorbaMessageMediator messageMediator)`
`void`	`sendCancelRequestIfFinalFragmentNotSent()`
`boolean`	`sentFragment()`
`boolean`	`sentFullMessage()`
`void`	`setDIIException(Exception exception)`
`void`	`setDIIInfo(Request diiRequest)`
`void`	`setDispatchBuffer(ByteBuffer byteBuffer)`
`void`	`setDispatchHeader(Message msg)`
`void`	`setExecutePIInResponseConstructor(boolean b)`
`void`	`setExecuteRemoveThreadInfoInResponseConstructor(boolean b)`
`void`	`setExecuteReturnServantInResponseConstructor(boolean b)`
`void`	`setInputObject(InputObject inputObject)` Used to set the `InputObject` used for the message.
`void`	`setOutputObject(OutputObject outputObject)` Used to set the `OutputObject` used for the message.
`void`	`setProtocolHandler(CorbaProtocolHandler protocolHandler)`
`void`	`setReplyExceptionDetailMessage(String message)`
`void`	`setReplyHeader(LocateReplyOrReplyMessage header)`
`Exception`	`unmarshalDIIUserException(String repoId, InputStream is)`
`InputObject`	`waitForResponse()` Used to wait for a response for synchronous messages.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

orb
```
protected ORB orb
```

wrapper

protected ORBUtilSystemException wrapper

interceptorWrapper

protected InterceptorsSystemException interceptorWrapper

contactInfo
```
protected CorbaContactInfo contactInfo
```

connection
```
protected CorbaConnection connection
```

addrDisposition
```
protected short addrDisposition
```

outputObject
```
protected CDROutputObject outputObject
```

inputObject
```
protected CDRInputObject inputObject
```

messageHeader
```
protected Message messageHeader
```

requestHeader
```
protected RequestMessage requestHeader
```

replyHeader

protected LocateReplyOrReplyMessage replyHeader

replyExceptionDetailMessage

protected String replyExceptionDetailMessage

replyIOR
```
protected IOR replyIOR
```

requestIdInteger
```
protected Integer requestIdInteger
```

dispatchHeader
```
protected Message dispatchHeader
```

dispatchByteBuffer

protected ByteBuffer dispatchByteBuffer

streamFormatVersion
```
protected byte streamFormatVersion
```

streamFormatVersionSet

protected boolean streamFormatVersionSet

diiRequest
```
protected Request diiRequest
```

cancelRequestAlreadySent

protected boolean cancelRequestAlreadySent

protocolHandler

protected ProtocolHandler protocolHandler

_executeReturnServantInResponseConstructor

protected boolean _executeReturnServantInResponseConstructor

_executeRemoveThreadInfoInResponseConstructor

protected boolean _executeRemoveThreadInfoInResponseConstructor

_executePIInResponseConstructor

protected boolean _executePIInResponseConstructor

isThreadDone
```
protected boolean isThreadDone
```

Constructor Detail

CorbaMessageMediatorImpl

public CorbaMessageMediatorImpl(ORB orb,
                                ContactInfo contactInfo,
                                Connection connection,
                                GIOPVersion giopVersion,
                                IOR ior,
                                int requestId,
                                short addrDisposition,
                                String operationName,
                                boolean isOneWay)

CorbaMessageMediatorImpl

public CorbaMessageMediatorImpl(ORB orb,
                                Connection connection)

CorbaMessageMediatorImpl

public CorbaMessageMediatorImpl(ORB orb,
                                CorbaConnection connection,
                                Message dispatchHeader,
                                ByteBuffer byteBuffer)

Method Detail
- getBroker
```
public Broker getBroker()
```
  Description copied from interface: MessageMediator
  
  The Broker associated with an invocation.
  
  Specified by:
  
  getBroker in interface MessageMediator
  
  Returns:
  
  Broker
- getContactInfo
```
public ContactInfo getContactInfo()
```
  Description copied from interface: MessageMediator
  
  Get the ContactInfo which created this MessageMediator.
  
  Specified by:
  
  getContactInfo in interface MessageMediator
  
  Returns:
  
  ContactInfo
- getConnection
```
public Connection getConnection()
```
  Description copied from interface: MessageMediator
  
  Get the Connection on which this message is sent or received.
  
  Specified by:
  
  getConnection in interface MessageMediator
- initializeMessage
```
public void initializeMessage()
```
  Description copied from interface: MessageMediator
  
  Used to initialize message headers. Note: this should be moved to a RequestDispatcher.
  
  Specified by:
  
  initializeMessage in interface MessageMediator
- finishSendingRequest
```
public void finishSendingRequest()
```
  Description copied from interface: MessageMediator
  
  Used to send the message (or its last fragment). Note: this should be moved to a RequestDispatcher.
  
  Specified by:
  
  finishSendingRequest in interface MessageMediator
- waitForResponse
```
public InputObject waitForResponse()
```
  Description copied from interface: MessageMediator
  
  Used to wait for a response for synchronous messages.
  
  Specified by:
  
  waitForResponse in interface MessageMediator
- setOutputObject
```
public void setOutputObject(OutputObject outputObject)
```
  Description copied from interface: MessageMediator
  
  Used to set the OutputObject used for the message.
  
  Specified by:
  
  setOutputObject in interface MessageMediator
- getOutputObject
```
public OutputObject getOutputObject()
```
  Description copied from interface: MessageMediator
  
  Used to get the OutputObject used for the message.
  
  Specified by:
  
  getOutputObject in interface MessageMediator
  
  Returns:
  
  OutputObject
- setInputObject
```
public void setInputObject(InputObject inputObject)
```
  Description copied from interface: MessageMediator
  
  Used to set the InputObject used for the message.
  
  Specified by:
  
  setInputObject in interface MessageMediator
- getInputObject
```
public InputObject getInputObject()
```
  Description copied from interface: MessageMediator
  
  Used to get the InputObject used for the message.
  
  Specified by:
  
  getInputObject in interface MessageMediator
  
  Returns:
  
  InputObject
- setReplyHeader
```
public void setReplyHeader(LocateReplyOrReplyMessage header)
```
  Specified by:
  
  setReplyHeader in interface CorbaMessageMediator
- getLocateReplyHeader
```
public LocateReplyMessage getLocateReplyHeader()
```
  Specified by:
  
  getLocateReplyHeader in interface CorbaMessageMediator
- getReplyHeader
```
public ReplyMessage getReplyHeader()
```
  Specified by:
  
  getReplyHeader in interface CorbaMessageMediator
- setReplyExceptionDetailMessage
```
public void setReplyExceptionDetailMessage(String message)
```
  Specified by:
  
  setReplyExceptionDetailMessage in interface CorbaMessageMediator
- getRequestHeader
```
public RequestMessage getRequestHeader()
```
  Specified by:
  
  getRequestHeader in interface CorbaMessageMediator
- getGIOPVersion
```
public GIOPVersion getGIOPVersion()
```
  Specified by:
  
  getGIOPVersion in interface CorbaMessageMediator
- getEncodingVersion
```
public byte getEncodingVersion()
```
  Specified by:
  
  getEncodingVersion in interface CorbaMessageMediator
- getRequestId
```
public int getRequestId()
```
  Specified by:
  
  getRequestId in interface CorbaMessageMediator
- getRequestIdInteger
```
public Integer getRequestIdInteger()
```
  Specified by:
  
  getRequestIdInteger in interface CorbaMessageMediator
- isOneWay
```
public boolean isOneWay()
```
  Specified by:
  
  isOneWay in interface CorbaMessageMediator
- getAddrDisposition
```
public short getAddrDisposition()
```
  Specified by:
  
  getAddrDisposition in interface CorbaMessageMediator
- getOperationName
```
public String getOperationName()
```
  Specified by:
  
  getOperationName in interface CorbaMessageMediator
- getRequestServiceContexts
```
public ServiceContexts getRequestServiceContexts()
```
  Specified by:
  
  getRequestServiceContexts in interface CorbaMessageMediator
- getReplyServiceContexts
```
public ServiceContexts getReplyServiceContexts()
```
  Specified by:
  
  getReplyServiceContexts in interface CorbaMessageMediator
- sendCancelRequestIfFinalFragmentNotSent
```
public void sendCancelRequestIfFinalFragmentNotSent()
```
  Specified by:
  
  sendCancelRequestIfFinalFragmentNotSent in interface CorbaMessageMediator
- sentFullMessage
```
public boolean sentFullMessage()
```
- sentFragment
```
public boolean sentFragment()
```
- setDIIInfo
```
public void setDIIInfo(Request diiRequest)
```
  Specified by:
  
  setDIIInfo in interface CorbaMessageMediator
- isDIIRequest
```
public boolean isDIIRequest()
```
  Specified by:
  
  isDIIRequest in interface CorbaMessageMediator
- unmarshalDIIUserException
```
public Exception unmarshalDIIUserException(String repoId,
                                           InputStream is)
```
  Specified by:
  
  unmarshalDIIUserException in interface CorbaMessageMediator
- setDIIException
```
public void setDIIException(Exception exception)
```
  Specified by:
  
  setDIIException in interface CorbaMessageMediator
- handleDIIReply
```
public void handleDIIReply(InputStream inputStream)
```
  Specified by:
  
  handleDIIReply in interface CorbaMessageMediator
- getDispatchHeader
```
public Message getDispatchHeader()
```
  Specified by:
  
  getDispatchHeader in interface CorbaMessageMediator
- setDispatchHeader
```
public void setDispatchHeader(Message msg)
```
  Specified by:
  
  setDispatchHeader in interface CorbaMessageMediator
- getDispatchBuffer
```
public ByteBuffer getDispatchBuffer()
```
  Specified by:
  
  getDispatchBuffer in interface CorbaMessageMediator
- setDispatchBuffer
```
public void setDispatchBuffer(ByteBuffer byteBuffer)
```
  Specified by:
  
  setDispatchBuffer in interface CorbaMessageMediator
- getThreadPoolToUse
```
public int getThreadPoolToUse()
```
  Specified by:
  
  getThreadPoolToUse in interface CorbaMessageMediator
- getStreamFormatVersion
```
public byte getStreamFormatVersion()
```
  Specified by:
  
  getStreamFormatVersion in interface CorbaMessageMediator
- getStreamFormatVersionForReply
```
public byte getStreamFormatVersionForReply()
```
  If the RMI-IIOP maximum stream format version service context is present, it indicates the maximum stream format version we could use for the reply. If it isn't present, the default is 2 for GIOP 1.3 or greater, 1 for lower. This is only sent on requests. Clients can find out the server's maximum by looking for a tagged component in the IOR.
  
  Specified by:
  
  getStreamFormatVersionForReply in interface CorbaMessageMediator
- isSystemExceptionReply
```
public boolean isSystemExceptionReply()
```
  Specified by:
  
  isSystemExceptionReply in interface CorbaMessageMediator
- isUserExceptionReply
```
public boolean isUserExceptionReply()
```
  Specified by:
  
  isUserExceptionReply in interface CorbaMessageMediator
- isLocationForwardReply
```
public boolean isLocationForwardReply()
```
  Specified by:
  
  isLocationForwardReply in interface CorbaMessageMediator
- isDifferentAddrDispositionRequestedReply
```
public boolean isDifferentAddrDispositionRequestedReply()
```
  Specified by:
  
  isDifferentAddrDispositionRequestedReply in interface CorbaMessageMediator
- getAddrDispositionReply
```
public short getAddrDispositionReply()
```
  Specified by:
  
  getAddrDispositionReply in interface CorbaMessageMediator
- getForwardedIOR
```
public IOR getForwardedIOR()
```
  Specified by:
  
  getForwardedIOR in interface CorbaMessageMediator
- getSystemExceptionReply
```
public SystemException getSystemExceptionReply()
```
  Specified by:
  
  getSystemExceptionReply in interface CorbaMessageMediator
- getObjectKey
```
public ObjectKey getObjectKey()
```
  Specified by:
  
  getObjectKey in interface CorbaMessageMediator
- setProtocolHandler
```
public void setProtocolHandler(CorbaProtocolHandler protocolHandler)
```
  Specified by:
  
  setProtocolHandler in interface CorbaMessageMediator
- getProtocolHandler
```
public CorbaProtocolHandler getProtocolHandler()
```
  Specified by:
  
  getProtocolHandler in interface CorbaMessageMediator
- createReply
```
public 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 CorbaMessageMediator
  
  Specified by:
  
  createReply in interface ResponseHandler
  
  Returns:
  
  an OutputStream suitable for marshalling the reply.
  
  See Also:
  
  portable package comments for unimplemented features
- createExceptionReply
```
public 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 CorbaMessageMediator
  
  Specified by:
  
  createExceptionReply in interface ResponseHandler
  
  Returns:
  
  an OutputStream suitable for marshalling the exception ID and the user exception body.
- executeReturnServantInResponseConstructor
```
public boolean executeReturnServantInResponseConstructor()
```
  Specified by:
  
  executeReturnServantInResponseConstructor in interface CorbaMessageMediator
- setExecuteReturnServantInResponseConstructor
```
public void setExecuteReturnServantInResponseConstructor(boolean b)
```
  Specified by:
  
  setExecuteReturnServantInResponseConstructor in interface CorbaMessageMediator
- executeRemoveThreadInfoInResponseConstructor
```
public boolean executeRemoveThreadInfoInResponseConstructor()
```
  Specified by:
  
  executeRemoveThreadInfoInResponseConstructor in interface CorbaMessageMediator
- setExecuteRemoveThreadInfoInResponseConstructor
```
public void setExecuteRemoveThreadInfoInResponseConstructor(boolean b)
```
  Specified by:
  
  setExecuteRemoveThreadInfoInResponseConstructor in interface CorbaMessageMediator
- executePIInResponseConstructor
```
public boolean executePIInResponseConstructor()
```
  Specified by:
  
  executePIInResponseConstructor in interface CorbaMessageMediator
- setExecutePIInResponseConstructor
```
public void setExecutePIInResponseConstructor(boolean b)
```
  Specified by:
  
  setExecutePIInResponseConstructor in interface CorbaMessageMediator
- handleRequest
```
public boolean handleRequest(MessageMediator messageMediator)
```
  Description copied from interface: ProtocolHandler
  
  This method determines the type of an incoming message and dispatches it appropriately. For example, on the server side, it may find a ServerRequestDispatcher to handle the request. On the client-side it may signal a waiting thread to handle a reply.
  
  Specified by:
  
  handleRequest in interface ProtocolHandler
  
  Returns:
  
  deprecated
- handleInput
```
public void handleInput(Message header)
                 throws IOException
```
  Description copied from interface: MessageHandler
  
  Used for message types for which we don't have concrete classes, yet, such as CloseConnection and MessageError, as well as unknown types.
  
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(RequestMessage_1_0 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(RequestMessage_1_1 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(RequestMessage_1_2 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(ReplyMessage_1_0 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(ReplyMessage_1_1 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(ReplyMessage_1_2 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(LocateRequestMessage_1_0 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(LocateRequestMessage_1_1 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(LocateRequestMessage_1_2 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(LocateReplyMessage_1_0 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(LocateReplyMessage_1_1 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(LocateReplyMessage_1_2 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(FragmentMessage_1_1 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(FragmentMessage_1_2 header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- handleInput
```
public void handleInput(CancelRequestMessage header)
                 throws IOException
```
  Specified by:
  
  handleInput in interface MessageHandler
  
  Throws:
  
  IOException
- opAndId
```
protected String opAndId(CorbaMessageMediator mediator)
```
- handleRequest
```
public void handleRequest(RequestMessage msg,
                          CorbaMessageMediator messageMediator)
```
  Specified by:
  
  handleRequest in interface CorbaProtocolHandler
- handleRequest
```
public void handleRequest(LocateRequestMessage msg,
                          CorbaMessageMediator messageMediator)
```
  Specified by:
  
  handleRequest in interface CorbaProtocolHandler
- handleRequestRequest
```
protected void handleRequestRequest(CorbaMessageMediator messageMediator)
```
- handleLocateRequest
```
protected void handleLocateRequest(CorbaMessageMediator messageMediator)
```
- handleThrowableDuringServerDispatch
```
public void handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator,
                                                Throwable throwable,
                                                CompletionStatus completionStatus)
```
  Specified by:
  
  handleThrowableDuringServerDispatch in interface CorbaProtocolHandler
- handleThrowableDuringServerDispatch
```
protected void handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator,
                                                   Throwable throwable,
                                                   CompletionStatus completionStatus,
                                                   int iteration)
```
- convertThrowableToSystemException
```
protected SystemException convertThrowableToSystemException(Throwable throwable,
                                                            CompletionStatus completionStatus)
```
- handleAddressingDisposition
```
protected void handleAddressingDisposition(CorbaMessageMediator messageMediator,
                                           AddressingDispositionException ex)
```
- createResponse
```
public CorbaMessageMediator createResponse(CorbaMessageMediator messageMediator,
                                           ServiceContexts svc)
```
  Specified by:
  
  createResponse in interface CorbaProtocolHandler
- createUserExceptionResponse
```
public CorbaMessageMediator createUserExceptionResponse(CorbaMessageMediator messageMediator,
                                                        ServiceContexts svc)
```
  Specified by:
  
  createUserExceptionResponse in interface CorbaProtocolHandler
- createUnknownExceptionResponse
```
public CorbaMessageMediator createUnknownExceptionResponse(CorbaMessageMediator messageMediator,
                                                           UnknownException ex)
```
  Specified by:
  
  createUnknownExceptionResponse in interface CorbaProtocolHandler
- createSystemExceptionResponse
```
public CorbaMessageMediator createSystemExceptionResponse(CorbaMessageMediator messageMediator,
                                                          SystemException ex,
                                                          ServiceContexts svc)
```
  Specified by:
  
  createSystemExceptionResponse in interface CorbaProtocolHandler
- createLocationForward
```
public CorbaMessageMediator createLocationForward(CorbaMessageMediator messageMediator,
                                                  IOR ior,
                                                  ServiceContexts svc)
```
  Specified by:
  
  createLocationForward in interface CorbaProtocolHandler
- createResponseHelper
```
protected CorbaMessageMediator createResponseHelper(CorbaMessageMediator messageMediator,
                                                    ServiceContexts svc)
```
- createResponseHelper
```
protected CorbaMessageMediator createResponseHelper(CorbaMessageMediator messageMediator,
                                                    ServiceContexts svc,
                                                    boolean user)
```
- createResponseHelper
```
protected CorbaMessageMediator createResponseHelper(CorbaMessageMediator messageMediator,
                                                    ReplyMessage reply,
                                                    IOR ior)
```
- runServantPostInvoke
```
protected void runServantPostInvoke(CorbaMessageMediator messageMediator)
```
- runInterceptors
```
protected void runInterceptors(CorbaMessageMediator messageMediator,
                               ReplyMessage reply)
```
- runRemoveThreadInfo
```
protected void runRemoveThreadInfo(CorbaMessageMediator messageMediator)
```
- getServiceContextsForReply
```
protected ServiceContexts getServiceContextsForReply(CorbaMessageMediator messageMediator,
                                                     ServiceContexts contexts)
```

Class CorbaMessageMediatorImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

orb

wrapper

interceptorWrapper

contactInfo

connection

addrDisposition

outputObject

inputObject

messageHeader

requestHeader

replyHeader

replyExceptionDetailMessage

replyIOR

requestIdInteger

dispatchHeader

dispatchByteBuffer

streamFormatVersion

streamFormatVersionSet

diiRequest

cancelRequestAlreadySent

protocolHandler

_executeReturnServantInResponseConstructor

_executeRemoveThreadInfoInResponseConstructor

_executePIInResponseConstructor

isThreadDone

Constructor Detail

CorbaMessageMediatorImpl

CorbaMessageMediatorImpl

CorbaMessageMediatorImpl

Method Detail

getBroker

getContactInfo

getConnection

initializeMessage

finishSendingRequest

waitForResponse

setOutputObject

getOutputObject

setInputObject

getInputObject

setReplyHeader

getLocateReplyHeader

getReplyHeader

setReplyExceptionDetailMessage

getRequestHeader

getGIOPVersion

getEncodingVersion

getRequestId

getRequestIdInteger

isOneWay

getAddrDisposition

getOperationName

getRequestServiceContexts

getReplyServiceContexts

sendCancelRequestIfFinalFragmentNotSent

sentFullMessage

sentFragment

setDIIInfo

isDIIRequest

unmarshalDIIUserException

setDIIException

handleDIIReply

getDispatchHeader

setDispatchHeader

getDispatchBuffer

setDispatchBuffer

getThreadPoolToUse

getStreamFormatVersion

getStreamFormatVersionForReply

isSystemExceptionReply

isUserExceptionReply

isLocationForwardReply

isDifferentAddrDispositionRequestedReply

getAddrDispositionReply