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;

  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. /**

  43.  * @author Harold Carr

  44.  */

  45. public interface CorbaMessageMediator

  46.     extends

  47. 	MessageMediator,

  48. 	ResponseHandler

  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(); // 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 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.     ////////////////////////////////////////////////////

  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 createReply();

  108.     public org.omg.CORBA.portable.OutputStream 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.