KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > sun > corba > se > spi > protocol > CorbaMessageMediator


1 /*
2  * @(#)CorbaMessageMediator.java 1.32 04/06/21
3  *
4  * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
5  * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
6  */
7
8 package com.sun.corba.se.spi.protocol;
9
10 import java.nio.ByteBuffer JavaDoc;
11
12 import org.omg.CORBA.INTERNAL JavaDoc;
13 import org.omg.CORBA.SystemException JavaDoc;
14 import org.omg.CORBA.portable.ResponseHandler JavaDoc;
15 import org.omg.CORBA.portable.UnknownException JavaDoc;
16 import org.omg.CORBA_2_3.portable.InputStream JavaDoc;
17 import org.omg.CORBA_2_3.portable.OutputStream JavaDoc;
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 /**
43  * @author Harold Carr
44  */
45 public interface CorbaMessageMediator
46     extends
47     MessageMediator,
48     ResponseHandler JavaDoc
49 {
50     public void setReplyHeader(LocateReplyOrReplyMessage header);
51     public LocateReplyMessage getLocateReplyHeader();
52     public ReplyMessage getReplyHeader();
53     public void setReplyExceptionDetailMessage(String JavaDoc message);
54     public RequestMessage getRequestHeader();
55     public GIOPVersion getGIOPVersion();
56     public byte getEncodingVersion();
57     public int getRequestId();
58     public Integer JavaDoc getRequestIdInteger();
59     public boolean isOneWay();
60     public short getAddrDisposition();
61     public String JavaDoc getOperationName();
62     public ServiceContexts getRequestServiceContexts();
63     public ServiceContexts getReplyServiceContexts();
64     public Message getDispatchHeader();
65     public void setDispatchHeader(Message msg);
66     public ByteBuffer JavaDoc getDispatchBuffer();
67     public void setDispatchBuffer(ByteBuffer JavaDoc byteBuffer);
68     public int getThreadPoolToUse();
69     public byte getStreamFormatVersion(); // REVIST name ForRequest?
70 public byte getStreamFormatVersionForReply();
71
72     // REVISIT - not sure if the final fragment and DII stuff should
73 // go here.
74
75     public void sendCancelRequestIfFinalFragmentNotSent();
76
77     public void setDIIInfo(org.omg.CORBA.Request JavaDoc request);
78     public boolean isDIIRequest();
79     public Exception JavaDoc unmarshalDIIUserException(String JavaDoc repoId,
80                            InputStream JavaDoc inputStream);
81     public void setDIIException(Exception JavaDoc exception);
82     public void handleDIIReply(InputStream JavaDoc 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 JavaDoc getSystemExceptionReply();
92
93     ////////////////////////////////////////////////////
94 //
95 // Server side
96 //
97
98     public ObjectKey getObjectKey();
99     public void setProtocolHandler(CorbaProtocolHandler protocolHandler);
100     public CorbaProtocolHandler getProtocolHandler();
101
102     ////////////////////////////////////////////////////
103 //
104 // ResponseHandler
105 //
106
107     public org.omg.CORBA.portable.OutputStream JavaDoc createReply();
108     public org.omg.CORBA.portable.OutputStream JavaDoc createExceptionReply();
109
110     ////////////////////////////////////////////////////
111 //
112 // from core.ServerRequest
113 //
114
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 // End of file.
129
130
Popular Tags