1 7 8 package com.sun.corba.se.spi.protocol; 9 10 import java.nio.ByteBuffer ; 11 12 import org.omg.CORBA.INTERNAL ; 13 import org.omg.CORBA.SystemException ; 14 import org.omg.CORBA.portable.ResponseHandler ; 15 import org.omg.CORBA.portable.UnknownException ; 16 import org.omg.CORBA_2_3.portable.InputStream ; 17 import org.omg.CORBA_2_3.portable.OutputStream ; 18 19 import com.sun.corba.se.pept.broker.Broker; 20 import com.sun.corba.se.pept.protocol.MessageMediator; 21 import com.sun.corba.se.pept.encoding.InputObject; 22 import com.sun.corba.se.pept.encoding.OutputObject; 23 import com.sun.corba.se.pept.protocol.ProtocolHandler; 24 import com.sun.corba.se.pept.transport.Connection; 25 26 import com.sun.corba.se.spi.ior.IOR; 27 import com.sun.corba.se.spi.ior.ObjectKey; 28 import com.sun.corba.se.spi.ior.iiop.GIOPVersion; 29 import com.sun.corba.se.spi.protocol.CorbaProtocolHandler; 30 import com.sun.corba.se.spi.servicecontext.ServiceContexts; 31 32 import com.sun.corba.se.impl.protocol.giopmsgheaders.LocateReplyMessage; 33 import com.sun.corba.se.impl.protocol.giopmsgheaders.LocateReplyOrReplyMessage; 34 import com.sun.corba.se.impl.protocol.giopmsgheaders.Message; 35 import com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase; 36 import com.sun.corba.se.impl.protocol.giopmsgheaders.MessageHandler; 37 import com.sun.corba.se.impl.protocol.giopmsgheaders.ReplyMessage; 38 import com.sun.corba.se.impl.protocol.giopmsgheaders.ReplyMessage_1_0; 39 import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage; 40 import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage_1_0; 41 42 45 public interface CorbaMessageMediator 46 extends 47 MessageMediator, 48 ResponseHandler ![JavaDoc](../../../../../../../cmn/javadoc.gif) 49 { 50 public void setReplyHeader(LocateReplyOrReplyMessage header); 51 public LocateReplyMessage getLocateReplyHeader(); 52 public ReplyMessage getReplyHeader(); 53 public void setReplyExceptionDetailMessage(String message); 54 public RequestMessage getRequestHeader(); 55 public GIOPVersion getGIOPVersion(); 56 public byte getEncodingVersion(); 57 public int getRequestId(); 58 public Integer getRequestIdInteger(); 59 public boolean isOneWay(); 60 public short getAddrDisposition(); 61 public String getOperationName(); 62 public ServiceContexts getRequestServiceContexts(); 63 public ServiceContexts getReplyServiceContexts(); 64 public Message getDispatchHeader(); 65 public void setDispatchHeader(Message msg); 66 public ByteBuffer getDispatchBuffer(); 67 public void setDispatchBuffer(ByteBuffer byteBuffer); 68 public int getThreadPoolToUse(); 69 public byte getStreamFormatVersion(); public byte getStreamFormatVersionForReply(); 71 72 75 public void sendCancelRequestIfFinalFragmentNotSent(); 76 77 public void setDIIInfo(org.omg.CORBA.Request request); 78 public boolean isDIIRequest(); 79 public Exception unmarshalDIIUserException(String repoId, 80 InputStream inputStream); 81 public void setDIIException(Exception exception); 82 public void handleDIIReply(InputStream inputStream); 83 84 85 public boolean isSystemExceptionReply(); 86 public boolean isUserExceptionReply(); 87 public boolean isLocationForwardReply(); 88 public boolean isDifferentAddrDispositionRequestedReply(); 89 public short getAddrDispositionReply(); 90 public IOR getForwardedIOR(); 91 public SystemException getSystemExceptionReply(); 92 93 98 public ObjectKey getObjectKey(); 99 public void setProtocolHandler(CorbaProtocolHandler protocolHandler); 100 public CorbaProtocolHandler getProtocolHandler(); 101 102 107 public org.omg.CORBA.portable.OutputStream createReply(); 108 public org.omg.CORBA.portable.OutputStream createExceptionReply(); 109 110 115 public boolean executeReturnServantInResponseConstructor(); 116 117 public void setExecuteReturnServantInResponseConstructor(boolean b); 118 119 public boolean executeRemoveThreadInfoInResponseConstructor(); 120 121 public void setExecuteRemoveThreadInfoInResponseConstructor(boolean b); 122 123 public boolean executePIInResponseConstructor(); 124 125 public void setExecutePIInResponseConstructor( boolean b ); 126 } 127 128 130 | Popular Tags |