Save This Page
Home » openjdk-7 » com.sun.corba.se.impl » protocol » [javadoc | source]
com.sun.corba.se.impl.protocol
public class: CorbaMessageMediatorImpl [javadoc | source]
java.lang.Object
   com.sun.corba.se.impl.protocol.CorbaMessageMediatorImpl

All Implemented Interfaces:
    CorbaProtocolHandler, MessageHandler, CorbaMessageMediator

Field Summary
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     
Constructor:
 public CorbaMessageMediatorImpl(ORB orb,
    Connection connection) 
 public CorbaMessageMediatorImpl(ORB orb,
    CorbaConnection connection,
    Message dispatchHeader,
    ByteBuffer byteBuffer) 
 public CorbaMessageMediatorImpl(ORB orb,
    ContactInfo contactInfo,
    Connection connection,
    GIOPVersion giopVersion,
    IOR ior,
    int requestId,
    short addrDisposition,
    String operationName,
    boolean isOneWay) 
Method from com.sun.corba.se.impl.protocol.CorbaMessageMediatorImpl Summary:
convertThrowableToSystemException,   createExceptionReply,   createLocationForward,   createReply,   createResponse,   createResponseHelper,   createResponseHelper,   createResponseHelper,   createSystemExceptionResponse,   createUnknownExceptionResponse,   createUserExceptionResponse,   executePIInResponseConstructor,   executeRemoveThreadInfoInResponseConstructor,   executeReturnServantInResponseConstructor,   finishSendingRequest,   getAddrDisposition,   getAddrDispositionReply,   getBroker,   getConnection,   getContactInfo,   getDispatchBuffer,   getDispatchHeader,   getEncodingVersion,   getForwardedIOR,   getGIOPVersion,   getInputObject,   getLocateReplyHeader,   getObjectKey,   getOperationName,   getOutputObject,   getProtocolHandler,   getReplyHeader,   getReplyServiceContexts,   getRequestHeader,   getRequestId,   getRequestIdInteger,   getRequestServiceContexts,   getServiceContextsForReply,   getStreamFormatVersion,   getStreamFormatVersionForReply,   getSystemExceptionReply,   getThreadPoolToUse,   handleAddressingDisposition,   handleDIIReply,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleInput,   handleLocateRequest,   handleRequest,   handleRequest,   handleRequest,   handleRequestRequest,   handleThrowableDuringServerDispatch,   handleThrowableDuringServerDispatch,   initializeMessage,   isDIIRequest,   isDifferentAddrDispositionRequestedReply,   isLocationForwardReply,   isOneWay,   isSystemExceptionReply,   isUserExceptionReply,   opAndId,   runInterceptors,   runRemoveThreadInfo,   runServantPostInvoke,   sendCancelRequestIfFinalFragmentNotSent,   sentFragment,   sentFullMessage,   setDIIException,   setDIIInfo,   setDispatchBuffer,   setDispatchHeader,   setExecutePIInResponseConstructor,   setExecuteRemoveThreadInfoInResponseConstructor,   setExecuteReturnServantInResponseConstructor,   setInputObject,   setOutputObject,   setProtocolHandler,   setReplyExceptionDetailMessage,   setReplyHeader,   unmarshalDIIUserException,   waitForResponse
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from com.sun.corba.se.impl.protocol.CorbaMessageMediatorImpl Detail:
 protected SystemException convertThrowableToSystemException(Throwable throwable,
    CompletionStatus completionStatus) 
 public OutputStream createExceptionReply() 
 public CorbaMessageMediator createLocationForward(CorbaMessageMediator messageMediator,
    IOR ior,
    ServiceContexts svc) 
 public OutputStream createReply() 
 public CorbaMessageMediator createResponse(CorbaMessageMediator messageMediator,
    ServiceContexts svc) 
 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) 
 public CorbaMessageMediator createSystemExceptionResponse(CorbaMessageMediator messageMediator,
    SystemException ex,
    ServiceContexts svc) 
 public CorbaMessageMediator createUnknownExceptionResponse(CorbaMessageMediator messageMediator,
    UnknownException ex) 
 public CorbaMessageMediator createUserExceptionResponse(CorbaMessageMediator messageMediator,
    ServiceContexts svc) 
 public boolean executePIInResponseConstructor() 
 public boolean executeRemoveThreadInfoInResponseConstructor() 
 public boolean executeReturnServantInResponseConstructor() 
 public  void finishSendingRequest() 
 public short getAddrDisposition() 
 public short getAddrDispositionReply() 
 public Broker getBroker() 
 public Connection getConnection() 
 public ContactInfo getContactInfo() 
 public ByteBuffer getDispatchBuffer() 
 public Message getDispatchHeader() 
 public byte getEncodingVersion() 
 public IOR getForwardedIOR() 
 public GIOPVersion getGIOPVersion() 
 public InputObject getInputObject() 
 public LocateReplyMessage getLocateReplyHeader() 
 public ObjectKey getObjectKey() 
 public String getOperationName() 
 public OutputObject getOutputObject() 
 public CorbaProtocolHandler getProtocolHandler() 
 public ReplyMessage getReplyHeader() 
 public ServiceContexts getReplyServiceContexts() 
 public RequestMessage getRequestHeader() 
 public int getRequestId() 
 public Integer getRequestIdInteger() 
 public ServiceContexts getRequestServiceContexts() 
 protected ServiceContexts getServiceContextsForReply(CorbaMessageMediator messageMediator,
    ServiceContexts contexts) 
 public byte getStreamFormatVersion() 
 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.
 public SystemException getSystemExceptionReply() 
 public int getThreadPoolToUse() 
 protected  void handleAddressingDisposition(CorbaMessageMediator messageMediator,
    AddressingDispositionException ex) 
 public  void handleDIIReply(InputStream inputStream) 
 public  void handleInput(Message header) throws IOException 
 public  void handleInput(RequestMessage_1_0 header) throws IOException 
 public  void handleInput(RequestMessage_1_1 header) throws IOException 
 public  void handleInput(RequestMessage_1_2 header) throws IOException 
 public  void handleInput(ReplyMessage_1_0 header) throws IOException 
 public  void handleInput(ReplyMessage_1_1 header) throws IOException 
 public  void handleInput(ReplyMessage_1_2 header) throws IOException 
 public  void handleInput(LocateRequestMessage_1_0 header) throws IOException 
 public  void handleInput(LocateRequestMessage_1_1 header) throws IOException 
 public  void handleInput(LocateRequestMessage_1_2 header) throws IOException 
 public  void handleInput(LocateReplyMessage_1_0 header) throws IOException 
 public  void handleInput(LocateReplyMessage_1_1 header) throws IOException 
 public  void handleInput(LocateReplyMessage_1_2 header) throws IOException 
 public  void handleInput(FragmentMessage_1_1 header) throws IOException 
 public  void handleInput(FragmentMessage_1_2 header) throws IOException 
 public  void handleInput(CancelRequestMessage header) throws IOException 
 protected  void handleLocateRequest(CorbaMessageMediator messageMediator) 
 public boolean handleRequest(MessageMediator messageMediator) 
 public  void handleRequest(RequestMessage msg,
    CorbaMessageMediator messageMediator) 
 public  void handleRequest(LocateRequestMessage msg,
    CorbaMessageMediator messageMediator) 
 protected  void handleRequestRequest(CorbaMessageMediator messageMediator) 
 public  void handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator,
    Throwable throwable,
    CompletionStatus completionStatus) 
 protected  void handleThrowableDuringServerDispatch(CorbaMessageMediator messageMediator,
    Throwable throwable,
    CompletionStatus completionStatus,
    int iteration) 
 public  void initializeMessage() 
 public boolean isDIIRequest() 
 public boolean isDifferentAddrDispositionRequestedReply() 
 public boolean isLocationForwardReply() 
 public boolean isOneWay() 
 public boolean isSystemExceptionReply() 
 public boolean isUserExceptionReply() 
 protected String opAndId(CorbaMessageMediator mediator) 
 protected  void runInterceptors(CorbaMessageMediator messageMediator,
    ReplyMessage reply) 
 protected  void runRemoveThreadInfo(CorbaMessageMediator messageMediator) 
 protected  void runServantPostInvoke(CorbaMessageMediator messageMediator) 
 public  void sendCancelRequestIfFinalFragmentNotSent() 
 public boolean sentFragment() 
 public boolean sentFullMessage() 
 public  void setDIIException(Exception exception) 
 public  void setDIIInfo(Request diiRequest) 
 public  void setDispatchBuffer(ByteBuffer byteBuffer) 
 public  void setDispatchHeader(Message msg) 
 public  void setExecutePIInResponseConstructor(boolean b) 
 public  void setExecuteRemoveThreadInfoInResponseConstructor(boolean b) 
 public  void setExecuteReturnServantInResponseConstructor(boolean b) 
 public  void setInputObject(InputObject inputObject) 
 public  void setOutputObject(OutputObject outputObject) 
 public  void setProtocolHandler(CorbaProtocolHandler protocolHandler) 
 public  void setReplyExceptionDetailMessage(String message) 
 public  void setReplyHeader(LocateReplyOrReplyMessage header) 
 public Exception unmarshalDIIUserException(String repoId,
    InputStream is) 
 public InputObject waitForResponse()