Package com.sun.corba.se.impl.protocol

Class CorbaMessageMediatorImpl

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	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	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

Modifier and Type	Method	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)
void	handleRequest(RequestMessage msg, CorbaMessageMediator messageMediator)
boolean	handleRequest(MessageMediator messageMediator)	This method determines the type of an incoming message and dispatches it appropriately.
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 Details

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 Details

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 Details

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)