public class CorbaMessageMediatorImpl extends Object implements CorbaMessageMediator, CorbaProtocolHandler, MessageHandler
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) |
protected ORB orb
protected ORBUtilSystemException wrapper
protected InterceptorsSystemException interceptorWrapper
protected CorbaContactInfo contactInfo
protected CorbaConnection connection
protected short addrDisposition
protected CDROutputObject outputObject
protected CDRInputObject inputObject
protected Message messageHeader
protected RequestMessage requestHeader
protected LocateReplyOrReplyMessage replyHeader
protected String replyExceptionDetailMessage
protected IOR replyIOR
protected Integer requestIdInteger
protected Message dispatchHeader
protected ByteBuffer dispatchByteBuffer
protected byte streamFormatVersion
protected boolean streamFormatVersionSet
protected Request diiRequest
protected boolean cancelRequestAlreadySent
protected ProtocolHandler protocolHandler
protected boolean _executeReturnServantInResponseConstructor
protected boolean _executeRemoveThreadInfoInResponseConstructor
protected boolean _executePIInResponseConstructor
protected boolean isThreadDone
public CorbaMessageMediatorImpl(ORB orb, ContactInfo contactInfo, Connection connection, GIOPVersion giopVersion, IOR ior, int requestId, short addrDisposition, String operationName, boolean isOneWay)
public CorbaMessageMediatorImpl(ORB orb, Connection connection)
public CorbaMessageMediatorImpl(ORB orb, CorbaConnection connection, Message dispatchHeader, ByteBuffer byteBuffer)
public Broker getBroker()
MessageMediator
Broker
associated
with an invocation.getBroker
in interface MessageMediator
Broker
public ContactInfo getContactInfo()
MessageMediator
ContactInfo
which created this MessageMediator
.getContactInfo
in interface MessageMediator
ContactInfo
public Connection getConnection()
MessageMediator
Connection
on which this message is sent or received.getConnection
in interface MessageMediator
public void initializeMessage()
MessageMediator
RequestDispatcher
.initializeMessage
in interface MessageMediator
public void finishSendingRequest()
MessageMediator
RequestDispatcher
.finishSendingRequest
in interface MessageMediator
public InputObject waitForResponse()
MessageMediator
waitForResponse
in interface MessageMediator
public void setOutputObject(OutputObject outputObject)
MessageMediator
OutputObject
used for the message.setOutputObject
in interface MessageMediator
public OutputObject getOutputObject()
MessageMediator
OutputObject
used for the message.getOutputObject
in interface MessageMediator
OutputObject
public void setInputObject(InputObject inputObject)
MessageMediator
InputObject
used for the message.setInputObject
in interface MessageMediator
public InputObject getInputObject()
MessageMediator
InputObject
used for the message.getInputObject
in interface MessageMediator
InputObject
public void setReplyHeader(LocateReplyOrReplyMessage header)
setReplyHeader
in interface CorbaMessageMediator
public LocateReplyMessage getLocateReplyHeader()
getLocateReplyHeader
in interface CorbaMessageMediator
public ReplyMessage getReplyHeader()
getReplyHeader
in interface CorbaMessageMediator
public void setReplyExceptionDetailMessage(String message)
setReplyExceptionDetailMessage
in interface CorbaMessageMediator
public RequestMessage getRequestHeader()
getRequestHeader
in interface CorbaMessageMediator
public GIOPVersion getGIOPVersion()
getGIOPVersion
in interface CorbaMessageMediator
public byte getEncodingVersion()
getEncodingVersion
in interface CorbaMessageMediator
public int getRequestId()
getRequestId
in interface CorbaMessageMediator
public Integer getRequestIdInteger()
getRequestIdInteger
in interface CorbaMessageMediator
public boolean isOneWay()
isOneWay
in interface CorbaMessageMediator
public short getAddrDisposition()
getAddrDisposition
in interface CorbaMessageMediator
public String getOperationName()
getOperationName
in interface CorbaMessageMediator
public ServiceContexts getRequestServiceContexts()
getRequestServiceContexts
in interface CorbaMessageMediator
public ServiceContexts getReplyServiceContexts()
getReplyServiceContexts
in interface CorbaMessageMediator
public void sendCancelRequestIfFinalFragmentNotSent()
sendCancelRequestIfFinalFragmentNotSent
in interface CorbaMessageMediator
public boolean sentFullMessage()
public boolean sentFragment()
public void setDIIInfo(Request diiRequest)
setDIIInfo
in interface CorbaMessageMediator
public boolean isDIIRequest()
isDIIRequest
in interface CorbaMessageMediator
public Exception unmarshalDIIUserException(String repoId, InputStream is)
unmarshalDIIUserException
in interface CorbaMessageMediator
public void setDIIException(Exception exception)
setDIIException
in interface CorbaMessageMediator
public void handleDIIReply(InputStream inputStream)
handleDIIReply
in interface CorbaMessageMediator
public Message getDispatchHeader()
getDispatchHeader
in interface CorbaMessageMediator
public void setDispatchHeader(Message msg)
setDispatchHeader
in interface CorbaMessageMediator
public ByteBuffer getDispatchBuffer()
getDispatchBuffer
in interface CorbaMessageMediator
public void setDispatchBuffer(ByteBuffer byteBuffer)
setDispatchBuffer
in interface CorbaMessageMediator
public int getThreadPoolToUse()
getThreadPoolToUse
in interface CorbaMessageMediator
public byte getStreamFormatVersion()
getStreamFormatVersion
in interface CorbaMessageMediator
public byte getStreamFormatVersionForReply()
getStreamFormatVersionForReply
in interface CorbaMessageMediator
public boolean isSystemExceptionReply()
isSystemExceptionReply
in interface CorbaMessageMediator
public boolean isUserExceptionReply()
isUserExceptionReply
in interface CorbaMessageMediator
public boolean isLocationForwardReply()
isLocationForwardReply
in interface CorbaMessageMediator
public boolean isDifferentAddrDispositionRequestedReply()
isDifferentAddrDispositionRequestedReply
in interface CorbaMessageMediator
public short getAddrDispositionReply()
getAddrDispositionReply
in interface CorbaMessageMediator
public IOR getForwardedIOR()
getForwardedIOR
in interface CorbaMessageMediator
public SystemException getSystemExceptionReply()
getSystemExceptionReply
in interface CorbaMessageMediator
public ObjectKey getObjectKey()
getObjectKey
in interface CorbaMessageMediator
public void setProtocolHandler(CorbaProtocolHandler protocolHandler)
setProtocolHandler
in interface CorbaMessageMediator
public CorbaProtocolHandler getProtocolHandler()
getProtocolHandler
in interface CorbaMessageMediator
public OutputStream createReply()
ResponseHandler
createReply
in interface CorbaMessageMediator
createReply
in interface ResponseHandler
portable
package comments for unimplemented featurespublic OutputStream createExceptionReply()
ResponseHandler
createExceptionReply
in interface CorbaMessageMediator
createExceptionReply
in interface ResponseHandler
public boolean executeReturnServantInResponseConstructor()
executeReturnServantInResponseConstructor
in interface CorbaMessageMediator
public void setExecuteReturnServantInResponseConstructor(boolean b)
setExecuteReturnServantInResponseConstructor
in interface CorbaMessageMediator
public boolean executeRemoveThreadInfoInResponseConstructor()
executeRemoveThreadInfoInResponseConstructor
in interface CorbaMessageMediator
public void setExecuteRemoveThreadInfoInResponseConstructor(boolean b)
setExecuteRemoveThreadInfoInResponseConstructor
in interface CorbaMessageMediator
public boolean executePIInResponseConstructor()
executePIInResponseConstructor
in interface CorbaMessageMediator
public void setExecutePIInResponseConstructor(boolean b)
setExecutePIInResponseConstructor
in interface CorbaMessageMediator
public boolean handleRequest(MessageMediator messageMediator)
ProtocolHandler
ServerRequestDispatcher
to handle the request. On the client-side
it may signal a waiting thread to handle a reply.handleRequest
in interface ProtocolHandler
public void handleInput(Message header) throws IOException
MessageHandler
handleInput
in interface MessageHandler
IOException
public void handleInput(RequestMessage_1_0 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(RequestMessage_1_1 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(RequestMessage_1_2 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(ReplyMessage_1_0 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(ReplyMessage_1_1 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(ReplyMessage_1_2 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(LocateRequestMessage_1_0 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(LocateRequestMessage_1_1 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(LocateRequestMessage_1_2 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(LocateReplyMessage_1_0 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(LocateReplyMessage_1_1 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(LocateReplyMessage_1_2 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(FragmentMessage_1_1 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(FragmentMessage_1_2 header) throws IOException
handleInput
in interface MessageHandler
IOException
public void handleInput(CancelRequestMessage header) throws IOException
handleInput
in interface MessageHandler
IOException
protected String opAndId(CorbaMessageMediator mediator)
public void handleRequest(RequestMessage msg, CorbaMessageMediator messageMediator)
handleRequest
in interface CorbaProtocolHandler
public void handleRequest(LocateRequestMessage msg, CorbaMessageMediator messageMediator)
handleRequest
in interface CorbaProtocolHandler
protected void handleRequestRequest(CorbaMessageMediator messageMediator)
protected void handleLocateRequest(CorbaMessageMediator messageMediator)
public void handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus)
handleThrowableDuringServerDispatch
in interface CorbaProtocolHandler
protected void handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus, int iteration)
protected SystemException convertThrowableToSystemException(Throwable throwable, CompletionStatus completionStatus)
protected void handleAddressingDisposition(CorbaMessageMediator messageMediator, AddressingDispositionException ex)
public CorbaMessageMediator createResponse(CorbaMessageMediator messageMediator, ServiceContexts svc)
createResponse
in interface CorbaProtocolHandler
public CorbaMessageMediator createUserExceptionResponse(CorbaMessageMediator messageMediator, ServiceContexts svc)
createUserExceptionResponse
in interface CorbaProtocolHandler
public CorbaMessageMediator createUnknownExceptionResponse(CorbaMessageMediator messageMediator, UnknownException ex)
createUnknownExceptionResponse
in interface CorbaProtocolHandler
public CorbaMessageMediator createSystemExceptionResponse(CorbaMessageMediator messageMediator, SystemException ex, ServiceContexts svc)
createSystemExceptionResponse
in interface CorbaProtocolHandler
public CorbaMessageMediator createLocationForward(CorbaMessageMediator messageMediator, IOR ior, ServiceContexts svc)
createLocationForward
in interface CorbaProtocolHandler
protected CorbaMessageMediator createResponseHelper(CorbaMessageMediator messageMediator, ServiceContexts svc)
protected CorbaMessageMediator createResponseHelper(CorbaMessageMediator messageMediator, ServiceContexts svc, boolean user)
protected CorbaMessageMediator createResponseHelper(CorbaMessageMediator messageMediator, ReplyMessage reply, IOR ior)
protected void runServantPostInvoke(CorbaMessageMediator messageMediator)
protected void runInterceptors(CorbaMessageMediator messageMediator, ReplyMessage reply)
protected void runRemoveThreadInfo(CorbaMessageMediator messageMediator)
protected ServiceContexts getServiceContextsForReply(CorbaMessageMediator messageMediator, ServiceContexts contexts)
Copyright © 2017 JBoss by Red Hat. All rights reserved.