Package com.sun.corba.ee.impl.protocol

Class MessageMediatorImpl

java.lang.Object

com.sun.corba.ee.impl.protocol.MessageMediatorImpl

All Implemented Interfaces:

MessageHandler, MessageMediator, ProtocolHandler, Work, ResponseHandler

public class MessageMediatorImpl
extends Object
implements MessageMediator, ProtocolHandler, MessageHandler, Work

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	_executePIInResponseConstructor
protected boolean	_executeRemoveThreadInfoInResponseConstructor
protected boolean	_executeReturnServantInResponseConstructor
protected short	addrDisposition
protected boolean	cancelRequestAlreadySent
protected Connection	connection
protected ContactInfo	contactInfo
protected Request	diiRequest
protected ByteBuffer	dispatchByteBuffer
protected Message	dispatchHeader
private long	enqueueTime
protected CDRInputObject	inputObject
protected static final InterceptorsSystemException	interceptorWrapper
protected boolean	isThreadDone
private static byte	localMaxVersion
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 byte	streamFormatVersion
protected boolean	streamFormatVersionSet
protected static final ORBUtilSystemException	wrapper

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MessageMediatorImpl(ORB orb, Connection connection)
	MessageMediatorImpl(ORB orb, Connection connection, Message dispatchHeader, ByteBuffer byteBuffer)
	MessageMediatorImpl(ORB orb, ContactInfo contactInfo, Connection connection, GIOPVersion giopVersion, IOR ior, int requestId, short addrDisposition, String operationName, boolean isOneWay)

Method Summary

Modifier and Type	Method	Description
private void	addExceptionDetailMessage(MessageMediator mediator, SystemException ex, ServiceContexts serviceContexts)
private void	addMessageMediatorToWorkQueue(MessageMediator messageMediator)
private void	beginRequest(MessageMediator messageMediator)
void	cancelRequest()
private void	connectionInfo(Connection conn)
protected SystemException	convertThrowableToSystemException(Throwable throwable, CompletionStatus completionStatus)
private CDROutputObject	createAppropriateOutputObject(MessageMediator messageMediator, Message msg, LocateReplyMessage reply)
OutputStream	createExceptionReply()	Called by the servant during a method invocation.
MessageMediator	createLocationForward(MessageMediator messageMediator, IOR ior, ServiceContexts svc)
OutputStream	createReply()	Called by the servant during a method invocation.
MessageMediator	createResponse(MessageMediator messageMediator, ServiceContexts svc)
protected MessageMediator	createResponseHelper(MessageMediator messageMediator, ReplyMessage reply, IOR ior)
protected MessageMediator	createResponseHelper(MessageMediator messageMediator, ServiceContexts svc)
protected MessageMediator	createResponseHelper(MessageMediator messageMediator, ServiceContexts svc, boolean user)
private void	createResponseHelperInfo(ReplyMessage reply)
MessageMediator	createSystemExceptionResponse(MessageMediator messageMediator, SystemException ex, ServiceContexts svc)
MessageMediator	createUnknownExceptionResponse(MessageMediator messageMediator, UnknownException ex)
MessageMediator	createUserExceptionResponse(MessageMediator messageMediator, ServiceContexts svc)
boolean	dispatch()	NOTE: This call is the transition from the transport block to the protocol block.
private void	dispatchError(MessageMediator messageMediator, String msg, Throwable t)
void	doWork()	Execute dispatch in its own WorkerThread.
private void	endRequest(MessageMediator messageMediator)
boolean	executePIInResponseConstructor()
boolean	executeRemoveThreadInfoInResponseConstructor()
boolean	executeReturnServantInResponseConstructor()
void	finishSendingRequest()	Used to send the message (or its last fragment).
private void	generalMessage(String msg)
short	getAddrDispositionReply()
ORB	getBroker()
Connection	getConnection()
ContactInfo	getContactInfo()
Message	getDispatchHeader()
byte	getEncodingVersion()
long	getEnqueueTime()	This methods gets the time in millis in the work item, when this work item was enqueued in the work queue.
IOR	getForwardedIOR()
GIOPVersion	getGIOPVersion()
CDRInputObject	getInputObject()
LocateReplyMessage	getLocateReplyHeader()
String	getName()	This method will return the name of the work item.
ObjectKeyCacheEntry	getObjectKeyCacheEntry()
String	getOperationName()
CDROutputObject	getOutputObject()
ProtocolHandler	getProtocolHandler()
ReplyMessage	getReplyHeader()
ServiceContexts	getReplyServiceContexts()
RequestMessage	getRequestHeader()
int	getRequestId()
RequestId	getRequestIdFromRawBytes()
ServiceContexts	getRequestServiceContexts()
protected ServiceContexts	getServiceContextsForReply(MessageMediator 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.
private byte	getStreamFormatVersionForThisRequest(IOR ior, GIOPVersion giopVersion)
SystemException	getSystemExceptionReply()
int	getThreadPoolToUse()
protected void	handleAddressingDisposition(MessageMediator 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(MessageMediator messageMediator)
void	handleRequest(LocateRequestMessage msg, MessageMediator messageMediator)
void	handleRequest(RequestMessage msg, MessageMediator messageMediator)
boolean	handleRequest(MessageMediator messageMediator)
protected void	handleRequestRequest(MessageMediator messageMediator)
void	handleThrowableDuringServerDispatch(MessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus)
protected void	handleThrowableDuringServerDispatch(MessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus, int iteration)
private void	ignoringThrowable(Throwable thr)
void	initializeMessage()	Used to initialize message headers.
boolean	isDifferentAddrDispositionRequestedReply()
boolean	isDIIRequest()
boolean	isLocationForwardReply()
boolean	isOneWay()
boolean	isSystemExceptionReply()
boolean	isUserExceptionReply()
private void	messageInfo(Message msg, RequestId rid)
private void	moreFragmentsInfo(boolean moreFragments)
private void	poolToUseInfo(int id)
private void	processCancelRequest(int cancelReqId)
private void	releaseByteBufferToPool()
private void	reportConnection(Connection conn)
private void	reportException(String msg, Throwable thr)
private void	reportGIOPVersion(GIOPVersion vers)
private void	requestIdInfo(int id)
private void	resumeOptimizedReadProcessing(Message message)
protected void	runInterceptors(MessageMediator messageMediator, ReplyMessage reply)
protected void	runRemoveThreadInfo(MessageMediator messageMediator)
protected void	runServantPostInvoke(MessageMediator messageMediator)
void	sendCancelRequestIfFinalFragmentNotSent()
private void	sendResponse(MessageMediator messageMediator)
boolean	sentFragment()
boolean	sentFullMessage()
void	setDIIException(Exception exception)
void	setDIIInfo(Request diiRequest)
void	setEnqueueTime(long timeInMillis)	This methods sets the time in millis in the work item, when this work item was enqueued in the work queue.
void	setExecutePIInResponseConstructor(boolean b)
void	setExecuteRemoveThreadInfoInResponseConstructor(boolean b)
void	setExecuteReturnServantInResponseConstructor(boolean b)
private void	setInputObject()
void	setInputObject(CDRInputObject inputObject)
void	setOutputObject(CDROutputObject outputObject)
void	setReplyExceptionDetailMessage(String message)
void	setReplyHeader(LocateReplyOrReplyMessage header)
void	setRequestServiceContexts(ServiceContexts sc)
private void	setWorkThenPoolOrResumeOptimizedRead(Message header)
private void	setWorkThenReadOrResumeOptimizedRead(Message header)
private void	signalResponseReceived()
private void	throwNotImplemented(String msg)
Exception	unmarshalDIIUserException(String repoId, InputStream is)
private void	unmarshalRequestID(Message_1_2 message)
CDRInputObject	waitForResponse()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

wrapper

protected static final ORBUtilSystemException wrapper

interceptorWrapper

protected static final InterceptorsSystemException interceptorWrapper

orb

protected ORB orb

contactInfo

protected ContactInfo contactInfo

connection

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

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

localMaxVersion

private static byte localMaxVersion

enqueueTime

private long enqueueTime

isThreadDone

protected boolean isThreadDone

Constructor Details

MessageMediatorImpl

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

MessageMediatorImpl

private MessageMediatorImpl(ORB orb,
 Connection connection)

MessageMediatorImpl

public MessageMediatorImpl(ORB orb,
 Connection connection,
 Message dispatchHeader,
 ByteBuffer byteBuffer)

Method Details

getRequestIdFromRawBytes

public RequestId getRequestIdFromRawBytes()

Specified by:

getRequestIdFromRawBytes in interface MessageMediator

getBroker

public ORB getBroker()

Specified by:

getBroker in interface MessageMediator

getContactInfo

public ContactInfo getContactInfo()

Specified by:

getContactInfo in interface MessageMediator

getConnection

public Connection getConnection()

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 CDRInputObject waitForResponse()

Specified by:

waitForResponse in interface MessageMediator

setOutputObject

public void setOutputObject(CDROutputObject outputObject)

Specified by:

setOutputObject in interface MessageMediator

getOutputObject

public CDROutputObject getOutputObject()

Specified by:

getOutputObject in interface MessageMediator

setInputObject

public void setInputObject(CDRInputObject inputObject)

Specified by:

setInputObject in interface MessageMediator

getInputObject

public CDRInputObject getInputObject()

Specified by:

getInputObject in interface MessageMediator

setReplyHeader

public void setReplyHeader(LocateReplyOrReplyMessage header)

Specified by:

setReplyHeader in interface MessageMediator

getLocateReplyHeader

public LocateReplyMessage getLocateReplyHeader()

Specified by:

getLocateReplyHeader in interface MessageMediator

getReplyHeader

public ReplyMessage getReplyHeader()

Specified by:

getReplyHeader in interface MessageMediator

setReplyExceptionDetailMessage

public void setReplyExceptionDetailMessage(String message)

Specified by:

setReplyExceptionDetailMessage in interface MessageMediator

getRequestHeader

public RequestMessage getRequestHeader()

Specified by:

getRequestHeader in interface MessageMediator

getGIOPVersion

public GIOPVersion getGIOPVersion()

Specified by:

getGIOPVersion in interface MessageMediator

getEncodingVersion

public byte getEncodingVersion()

Specified by:

getEncodingVersion in interface MessageMediator

getRequestId

public int getRequestId()

Specified by:

getRequestId in interface MessageMediator

isOneWay

public boolean isOneWay()

Specified by:

isOneWay in interface MessageMediator

getOperationName

public String getOperationName()

Specified by:

getOperationName in interface MessageMediator

getRequestServiceContexts

public ServiceContexts getRequestServiceContexts()

Specified by:

getRequestServiceContexts in interface MessageMediator

setRequestServiceContexts

public void setRequestServiceContexts(ServiceContexts sc)

Specified by:

setRequestServiceContexts in interface MessageMediator

getReplyServiceContexts

public ServiceContexts getReplyServiceContexts()

Specified by:

getReplyServiceContexts in interface MessageMediator

sendCancelRequestIfFinalFragmentNotSent

public void sendCancelRequestIfFinalFragmentNotSent()

Specified by:

sendCancelRequestIfFinalFragmentNotSent in interface MessageMediator

sentFullMessage

public boolean sentFullMessage()

sentFragment

public boolean sentFragment()

setDIIInfo

public void setDIIInfo(Request diiRequest)

Specified by:

setDIIInfo in interface MessageMediator

isDIIRequest

public boolean isDIIRequest()

Specified by:

isDIIRequest in interface MessageMediator

unmarshalDIIUserException

public Exception unmarshalDIIUserException(String repoId,
 InputStream is)

Specified by:

unmarshalDIIUserException in interface MessageMediator

setDIIException

public void setDIIException(Exception exception)

Specified by:

setDIIException in interface MessageMediator

handleDIIReply

public void handleDIIReply(InputStream inputStream)

Specified by:

handleDIIReply in interface MessageMediator

getDispatchHeader

public Message getDispatchHeader()

Specified by:

getDispatchHeader in interface MessageMediator

getThreadPoolToUse

public int getThreadPoolToUse()

Specified by:

getThreadPoolToUse in interface MessageMediator

reportException

@InfoMethod
private void reportException(String msg,
 Throwable thr)

reportConnection

@InfoMethod
private void reportConnection(Connection conn)

dispatch

public boolean dispatch()

NOTE: This call is the transition from the transport block to the protocol block.

Specified by:

dispatch in interface MessageMediator

getStreamFormatVersion

public byte getStreamFormatVersion()

Specified by:

getStreamFormatVersion in interface MessageMediator

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 MessageMediator

isSystemExceptionReply

public boolean isSystemExceptionReply()

Specified by:

isSystemExceptionReply in interface MessageMediator

isUserExceptionReply

public boolean isUserExceptionReply()

Specified by:

isUserExceptionReply in interface MessageMediator

isLocationForwardReply

public boolean isLocationForwardReply()

Specified by:

isLocationForwardReply in interface MessageMediator

isDifferentAddrDispositionRequestedReply

public boolean isDifferentAddrDispositionRequestedReply()

Specified by:

isDifferentAddrDispositionRequestedReply in interface MessageMediator

getAddrDispositionReply

public short getAddrDispositionReply()

Specified by:

getAddrDispositionReply in interface MessageMediator

getForwardedIOR

public IOR getForwardedIOR()

Specified by:

getForwardedIOR in interface MessageMediator

getSystemExceptionReply

public SystemException getSystemExceptionReply()

Specified by:

getSystemExceptionReply in interface MessageMediator

getObjectKeyCacheEntry

public ObjectKeyCacheEntry getObjectKeyCacheEntry()

Specified by:

getObjectKeyCacheEntry in interface MessageMediator

getProtocolHandler

public ProtocolHandler getProtocolHandler()

Specified by:

getProtocolHandler in interface MessageMediator

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 MessageMediator

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 MessageMediator

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 MessageMediator

setExecuteReturnServantInResponseConstructor

public void setExecuteReturnServantInResponseConstructor(boolean b)

Specified by:

setExecuteReturnServantInResponseConstructor in interface MessageMediator

executeRemoveThreadInfoInResponseConstructor

public boolean executeRemoveThreadInfoInResponseConstructor()

Specified by:

executeRemoveThreadInfoInResponseConstructor in interface MessageMediator

setExecuteRemoveThreadInfoInResponseConstructor

public void setExecuteRemoveThreadInfoInResponseConstructor(boolean b)

Specified by:

setExecuteRemoveThreadInfoInResponseConstructor in interface MessageMediator

executePIInResponseConstructor

public boolean executePIInResponseConstructor()

Specified by:

executePIInResponseConstructor in interface MessageMediator

setExecutePIInResponseConstructor

public void setExecutePIInResponseConstructor(boolean b)

Specified by:

setExecutePIInResponseConstructor in interface MessageMediator

getStreamFormatVersionForThisRequest

private byte getStreamFormatVersionForThisRequest(IOR ior,
 GIOPVersion giopVersion)

handleRequest

public boolean handleRequest(MessageMediator messageMediator)

Specified by:

handleRequest in interface ProtocolHandler

messageInfo

@InfoMethod
private void messageInfo(Message msg,
 RequestId rid)

connectionInfo

@InfoMethod
private void connectionInfo(Connection conn)

resumeOptimizedReadProcessing

private void resumeOptimizedReadProcessing(Message message)

poolToUseInfo

@InfoMethod
private void poolToUseInfo(int id)

addMessageMediatorToWorkQueue

private void addMessageMediatorToWorkQueue(MessageMediator messageMediator)

setWorkThenPoolOrResumeOptimizedRead

private void setWorkThenPoolOrResumeOptimizedRead(Message header)

setWorkThenReadOrResumeOptimizedRead

private void setWorkThenReadOrResumeOptimizedRead(Message header)

setInputObject

private void setInputObject()

signalResponseReceived

private void signalResponseReceived()

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

Parameters:

header - Message to handle

Throws:

IOException - If an IO error occurs

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

requestIdInfo

@InfoMethod
private void requestIdInfo(int id)

handleInput

public void handleInput(RequestMessage_1_2 header)
                 throws IOException

Specified by:

handleInput in interface MessageHandler

Throws:

IOException

unmarshalRequestID

private void unmarshalRequestID(Message_1_2 message)

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

moreFragmentsInfo

@InfoMethod
private void moreFragmentsInfo(boolean moreFragments)

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

reportGIOPVersion

@InfoMethod
private void reportGIOPVersion(GIOPVersion vers)

handleInput

public void handleInput(CancelRequestMessage header)
                 throws IOException

Specified by:

handleInput in interface MessageHandler

Throws:

IOException

throwNotImplemented

private void throwNotImplemented(String msg)

processCancelRequest

private void processCancelRequest(int cancelReqId)

handleRequest

public void handleRequest(RequestMessage msg,
 MessageMediator messageMediator)

Specified by:

handleRequest in interface ProtocolHandler

handleRequest

public void handleRequest(LocateRequestMessage msg,
 MessageMediator messageMediator)

Specified by:

handleRequest in interface ProtocolHandler

beginRequest

private void beginRequest(MessageMediator messageMediator)

dispatchError

private void dispatchError(MessageMediator messageMediator,
 String msg,
 Throwable t)

sendResponse

private void sendResponse(MessageMediator messageMediator)

endRequest

private void endRequest(MessageMediator messageMediator)

handleRequestRequest

protected void handleRequestRequest(MessageMediator messageMediator)

handleLocateRequest

protected void handleLocateRequest(MessageMediator messageMediator)

createAppropriateOutputObject

private CDROutputObject createAppropriateOutputObject(MessageMediator messageMediator,
 Message msg,
 LocateReplyMessage reply)

handleThrowableDuringServerDispatch

public void handleThrowableDuringServerDispatch(MessageMediator messageMediator,
 Throwable throwable,
 CompletionStatus completionStatus)

Specified by:

handleThrowableDuringServerDispatch in interface ProtocolHandler

handleThrowableDuringServerDispatch

protected void handleThrowableDuringServerDispatch(MessageMediator messageMediator,
 Throwable throwable,
 CompletionStatus completionStatus,
 int iteration)

convertThrowableToSystemException

protected SystemException convertThrowableToSystemException(Throwable throwable,
 CompletionStatus completionStatus)

handleAddressingDisposition

protected void handleAddressingDisposition(MessageMediator messageMediator,
 AddressingDispositionException ex)

createResponse

public MessageMediator createResponse(MessageMediator messageMediator,
 ServiceContexts svc)

Specified by:

createResponse in interface ProtocolHandler

createUserExceptionResponse

public MessageMediator createUserExceptionResponse(MessageMediator messageMediator,
 ServiceContexts svc)

Specified by:

createUserExceptionResponse in interface ProtocolHandler

createUnknownExceptionResponse

public MessageMediator createUnknownExceptionResponse(MessageMediator messageMediator,
 UnknownException ex)

Specified by:

createUnknownExceptionResponse in interface ProtocolHandler

createSystemExceptionResponse

public MessageMediator createSystemExceptionResponse(MessageMediator messageMediator,
 SystemException ex,
 ServiceContexts svc)

Specified by:

createSystemExceptionResponse in interface ProtocolHandler

addExceptionDetailMessage

private void addExceptionDetailMessage(MessageMediator mediator,
 SystemException ex,
 ServiceContexts serviceContexts)

createLocationForward

public MessageMediator createLocationForward(MessageMediator messageMediator,
 IOR ior,
 ServiceContexts svc)

Specified by:

createLocationForward in interface ProtocolHandler

createResponseHelper

protected MessageMediator createResponseHelper(MessageMediator messageMediator,
 ServiceContexts svc)

createResponseHelper

protected MessageMediator createResponseHelper(MessageMediator messageMediator,
 ServiceContexts svc,
 boolean user)

createResponseHelperInfo

@InfoMethod
private void createResponseHelperInfo(ReplyMessage reply)

createResponseHelper

protected MessageMediator createResponseHelper(MessageMediator messageMediator,
 ReplyMessage reply,
 IOR ior)

runServantPostInvoke

protected void runServantPostInvoke(MessageMediator messageMediator)

runInterceptors

protected void runInterceptors(MessageMediator messageMediator,
 ReplyMessage reply)

runRemoveThreadInfo

protected void runRemoveThreadInfo(MessageMediator messageMediator)

generalMessage

@InfoMethod
private void generalMessage(String msg)

getServiceContextsForReply

protected ServiceContexts getServiceContextsForReply(MessageMediator messageMediator,
 ServiceContexts contexts)

releaseByteBufferToPool

private void releaseByteBufferToPool()

cancelRequest

public void cancelRequest()

Specified by:

cancelRequest in interface MessageMediator

ignoringThrowable

@InfoMethod
private void ignoringThrowable(Throwable thr)

doWork

public void doWork()

Execute dispatch in its own WorkerThread. Prior to this method being called this object must be initialized with a valid connection (CorbaConnection), orb (ORB), dispatchHeader (Message) and dispatchByteBuffer (ByteBuffer).

Specified by:

doWork in interface Work

setEnqueueTime

public void setEnqueueTime(long timeInMillis)

Description copied from interface: Work

This methods sets the time in millis in the work item, when this work item was enqueued in the work queue.

Specified by:

setEnqueueTime in interface Work

getEnqueueTime

public long getEnqueueTime()

Description copied from interface: Work

This methods gets the time in millis in the work item, when this work item was enqueued in the work queue.

Specified by:

getEnqueueTime in interface Work

getName

public String getName()

Description copied from interface: Work

This method will return the name of the work item.

Specified by:

getName in interface Work