jp.co.nec.orb.GIOP
クラス Message

java.lang.Object
  |
  +--jp.co.nec.orb.GIOP.Message
すべての実装インタフェース:
Constant, ResponseHandler
直系の既知のサブクラス:
EncapsulateMessage, Message10, Message11, Message12

public abstract class Message
extends java.lang.Object
implements Constant, ResponseHandler

This is implementation class of GIOP Message Handler.


フィールドの概要
 ExtProtocol _ext_protocol
           
 int _interceptor_called_num
          for Portable Interceptors
 Policy[] _policy_list
           
 ServiceContextList _reply_scl
           
 ServiceContextList _request_scl
           
static int BUFFER_EXPAND_SIZE_ADDITION
           
static int SIZE_PER_WRITE
           
 
インタフェース jp.co.nec.orb.Constant から継承したフィールド
BIG_ENDIAN, GIOP_1_0, GIOP_1_1, GIOP_1_2, GIOP_ENCAPSULATE, LITTLE_ENDIAN
 
コンストラクタの概要
Message()
           
 
メソッドの概要
static IIOPOutputStreamImpl createCancelRequestMessage(SocketConnection scon, int requestid, int giopversion)
          Create OutputStream for sending Cancel Request Message
static IIOPOutputStreamImpl createCancelRequestMessage(SocketConnection scon, int requestid, IOR ior)
          Create OutputStream for sending Cancel Request Message
static IIOPOutputStreamImpl createCloseConnectionMessage(SocketConnection scon, int version)
           
static IIOPOutputStreamImpl createCloseConnectionMessage(SocketConnection scon, IOR ior)
          Create OutputStream for sending Close Connection Message
 OutputStream createExceptionReply()
          Called by servant during a method invocation.
static IIOPOutputStreamImpl createLocateReplyMessage(Message msg, int locatestatus)
          Create OutputStream for sending Locate Reply Message
static IIOPOutputStreamImpl createLocateRequestMessage(SocketConnection scon, int requestid, IOR ior, CodeSetContext csctx)
          Create OutputStream for sending Locate Request Message
static Message createMessage(int version)
          2000/06/01 add by osaki
static IIOPOutputStreamImpl createMessageErrorMessage(Message msg, SocketConnection scon)
          Create OutputStream for sending Message Error Message
 IIOPOutputStreamImpl createMessageErrorMessage(Message msg, SocketConnection scon, int minor)
          Create OutputStream for sending Message Error Message
 OutputStream createNopReply(int replystatus)
           
 OutputStream createReply()
          Called by servant during a method invocation.
static IIOPOutputStreamImpl createReplyMessage(Message request, int replystatus, ServiceContextList scl)
          Create OutputStream for sending Reply Message
static IIOPOutputStreamImpl createRequestMessage(SocketConnection scon, int requestid, Object target, IOR ior, ServiceContextList scl, java.lang.String ope, Principal prcpl, CodeSetContext csctx, boolean responseExpected, ORB orb)
          Create OutputStream for sending Request Message
static void dispatchReceiveMessage(SocketConnection scon)
          Create Message for receiving GIOP Message
 byte[] getBuffer()
           
abstract  byte[] getBuffer(int index)
           
static int getBufferExpandSize()
           
 StreamingRequestImpl getClientRequest()
           
 SystemException getException()
           
static boolean getFragmentMode()
           
abstract  int getGIOPVersion()
           
 IIOPInputStreamImpl getIIOPInputStream()
           
 IIOPOutputStreamImpl getIIOPOutputStream()
           
static boolean getLocateReplyAlign8()
           
 int getLocateReplyStatus()
           
 Message getMessageTop()
          get top message
 byte getMessageType()
           
 byte[] getObjectKey()
          Called from hook of WebOTX core
 ObjectKey getObjectKeyDecoded()
           
 java.lang.String getOperation()
           
static int getPositionDifferenceForInputStream(BufferPosition from, BufferPosition to)
          This methods is used by SocketInputStream and SocketOutputStream for getting difference between buffers.
static int getPositionDifferenceForOutputStream(BufferPosition from, BufferPosition to)
           
abstract  Principal getPrincipal()
           
 PropagationContext getPropagationContext()
           
 java.lang.Exception getRaisedException()
           
 Message getReplyMessage(long timeout)
          required from SocketConnection Return Reply Message
 int getReplyStatus()
           
 int getRequestID()
           
 ResponseHandler getResponseHandler()
          ResponseHandler
 ServiceContextList getSendingServiceContextList()
           
 Message getServerReplyMessage()
           
 ServiceContextList getServiceContextList()
           
 SocketConnection getSocketConnection()
           
static int getSocketWriteSize()
           
 SSLInfo getSSLInfo()
           
 Object getTarget()
           
 void handleReadingException(java.lang.Exception excp)
          required from SocketConnection Return Exception
 void handleWritingException(java.lang.Exception excp)
          required from SocketConnection Return Exception
 boolean hasServerReplyMessage()
           
abstract  boolean isFollowedFragmentData(byte[] message)
           
 boolean isHookNop()
           
 boolean isResponseExpected()
           
abstract  void movePositionForInputStream(BufferPosition pos, int move)
           
abstract  void movePositionForOutputStream(BufferPosition pos, int move)
           
static int new_trans_request_id()
           
 ORB orb()
           
 void orb(ORB orb)
           
 void postinvoke()
           
 boolean preinvoke(RequestHandler handler)
           
abstract  void prepareExpandedBuffer(int bufpos, int len, boolean expand)
           
abstract  void prepareNextBuffer()
           
static void putMessage(Message nouse)
           
 void putReply()
           
 void putUnexpectedUserException(java.lang.Exception e)
           
 boolean receiveCompleted()
          request by SocketConnection if all Message read true else false
 void releaseEncapsulateResource()
           
 void releaseResource()
           
 void releaseResource(boolean check_top)
           
abstract  void sendMessage(int bufpos)
           
 void setBuffer(byte[] buf)
           
static void setBufferExpandSize(int size)
           
 void setClientRequest(StreamingRequestImpl sri)
           
abstract  void setDIICall()
           
 void setException(SystemException excp)
          required from SocketConnection Return Exception
 void setExceptionToEnv(java.lang.Exception ex)
           
abstract  void setFragmentMessage(Message fragmentreply)
           
static void setFragmentMode(boolean b)
           
 void setIIOPOutputStream(IIOPOutputStreamImpl iosi)
           
static void setInvokationNoResponse(boolean response)
           
static void setLocateReplyAlign8(boolean align8)
           
 void setRaisedException(java.lang.Exception e)
           
 void setReplyMessage(Message reply)
          required from SocketConnection Set up receiver Message information to sender Message
 void setReplyStatus(int reply_status)
           
 void setResponseExpected(boolean expect)
           
 void setSendingServiceContextList(ServiceContextList scl)
           
 void setServerRequest(ServerRequestImpl sri)
           
static void setSocketWriteSize(int size)
           
 void setSSLInfo(SSLInfo si)
           
 void transactionCall(java.lang.Exception ex)
          this method must be called by the thread that called sending_request.
 
クラス java.lang.Object から継承したメソッド
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

BUFFER_EXPAND_SIZE_ADDITION

public static final int BUFFER_EXPAND_SIZE_ADDITION

SIZE_PER_WRITE

public static final int SIZE_PER_WRITE

_policy_list

public Policy[] _policy_list

_ext_protocol

public ExtProtocol _ext_protocol

_request_scl

public ServiceContextList _request_scl

_reply_scl

public ServiceContextList _reply_scl

_interceptor_called_num

public int _interceptor_called_num
for Portable Interceptors
コンストラクタの詳細

Message

public Message()
メソッドの詳細

setInvokationNoResponse

public static final void setInvokationNoResponse(boolean response)

setSocketWriteSize

public static final void setSocketWriteSize(int size)

getSocketWriteSize

public static final int getSocketWriteSize()

setFragmentMode

public static final void setFragmentMode(boolean b)

getFragmentMode

public static final boolean getFragmentMode()

setBufferExpandSize

public static final void setBufferExpandSize(int size)

getBufferExpandSize

public static final int getBufferExpandSize()

isHookNop

public boolean isHookNop()

setLocateReplyAlign8

public static void setLocateReplyAlign8(boolean align8)

getLocateReplyAlign8

public static boolean getLocateReplyAlign8()

setFragmentMessage

public abstract void setFragmentMessage(Message fragmentreply)

getPrincipal

public abstract Principal getPrincipal()

getGIOPVersion

public abstract int getGIOPVersion()

prepareExpandedBuffer

public abstract void prepareExpandedBuffer(int bufpos,
                                           int len,
                                           boolean expand)

prepareNextBuffer

public abstract void prepareNextBuffer()

sendMessage

public abstract void sendMessage(int bufpos)

isFollowedFragmentData

public abstract boolean isFollowedFragmentData(byte[] message)

movePositionForInputStream

public abstract void movePositionForInputStream(BufferPosition pos,
                                                int move)

movePositionForOutputStream

public abstract void movePositionForOutputStream(BufferPosition pos,
                                                 int move)

setDIICall

public abstract void setDIICall()

orb

public final void orb(ORB orb)

orb

public final ORB orb()

setIIOPOutputStream

public final void setIIOPOutputStream(IIOPOutputStreamImpl iosi)

getIIOPOutputStream

public final IIOPOutputStreamImpl getIIOPOutputStream()

getIIOPInputStream

public IIOPInputStreamImpl getIIOPInputStream()

getRequestID

public final int getRequestID()

setResponseExpected

public final void setResponseExpected(boolean expect)

isResponseExpected

public final boolean isResponseExpected()

getBuffer

public final byte[] getBuffer()

setBuffer

public final void setBuffer(byte[] buf)

getBuffer

public abstract byte[] getBuffer(int index)

getSocketConnection

public final SocketConnection getSocketConnection()

getMessageType

public final byte getMessageType()

getServiceContextList

public final ServiceContextList getServiceContextList()

setSendingServiceContextList

public final void setSendingServiceContextList(ServiceContextList scl)

getSendingServiceContextList

public final ServiceContextList getSendingServiceContextList()

getException

public final SystemException getException()

getRaisedException

public java.lang.Exception getRaisedException()

setRaisedException

public void setRaisedException(java.lang.Exception e)

getReplyStatus

public final int getReplyStatus()

getLocateReplyStatus

public final int getLocateReplyStatus()

setReplyStatus

public void setReplyStatus(int reply_status)

getOperation

public final java.lang.String getOperation()

receiveCompleted

public final boolean receiveCompleted()
request by SocketConnection if all Message read true else false
戻り値:
boolean

getServerReplyMessage

public final Message getServerReplyMessage()

hasServerReplyMessage

public final boolean hasServerReplyMessage()

getTarget

public Object getTarget()

getObjectKey

public final byte[] getObjectKey()
Called from hook of WebOTX core
戻り値:
 

getObjectKeyDecoded

public final ObjectKey getObjectKeyDecoded()

setServerRequest

public void setServerRequest(ServerRequestImpl sri)

setClientRequest

public void setClientRequest(StreamingRequestImpl sri)

getClientRequest

public StreamingRequestImpl getClientRequest()

createRequestMessage

public static final IIOPOutputStreamImpl createRequestMessage(SocketConnection scon,
                                                              int requestid,
                                                              Object target,
                                                              IOR ior,
                                                              ServiceContextList scl,
                                                              java.lang.String ope,
                                                              Principal prcpl,
                                                              CodeSetContext csctx,
                                                              boolean responseExpected,
                                                              ORB orb)
Create OutputStream for sending Request Message
パラメータ:
scon - SocketConnection
target - target object
scl - ServiceContextList
ope - operation name
prcpl - Proncipal of the Request
csctx - CodeSetContext
戻り値:
IIOPOutputStreamImpl

createReplyMessage

public static final IIOPOutputStreamImpl createReplyMessage(Message request,
                                                            int replystatus,
                                                            ServiceContextList scl)
Create OutputStream for sending Reply Message
パラメータ:
replystatus - ReplyStatus for ReplyMessage
scl - ServiceContextList
戻り値:
IIOPOutputStreamImpl

createCancelRequestMessage

public static IIOPOutputStreamImpl createCancelRequestMessage(SocketConnection scon,
                                                              int requestid,
                                                              IOR ior)
Create OutputStream for sending Cancel Request Message
戻り値:
IIOPOutputStreamImpl

createCancelRequestMessage

public static final IIOPOutputStreamImpl createCancelRequestMessage(SocketConnection scon,
                                                                    int requestid,
                                                                    int giopversion)
Create OutputStream for sending Cancel Request Message
戻り値:
IIOPOutputStreamImpl

createLocateRequestMessage

public static IIOPOutputStreamImpl createLocateRequestMessage(SocketConnection scon,
                                                              int requestid,
                                                              IOR ior,
                                                              CodeSetContext csctx)
Create OutputStream for sending Locate Request Message
戻り値:
IIOPOutputStreamImpl

createLocateReplyMessage

public static IIOPOutputStreamImpl createLocateReplyMessage(Message msg,
                                                            int locatestatus)
Create OutputStream for sending Locate Reply Message
戻り値:
IIOPOutputStreamImpl

createCloseConnectionMessage

public static IIOPOutputStreamImpl createCloseConnectionMessage(SocketConnection scon,
                                                                IOR ior)
Create OutputStream for sending Close Connection Message
戻り値:
IIOPOutputStreamImpl

createCloseConnectionMessage

public static IIOPOutputStreamImpl createCloseConnectionMessage(SocketConnection scon,
                                                                int version)

createMessageErrorMessage

public static IIOPOutputStreamImpl createMessageErrorMessage(Message msg,
                                                             SocketConnection scon)
Create OutputStream for sending Message Error Message
戻り値:
IIOPOutputStreamImpl

createMessageErrorMessage

public IIOPOutputStreamImpl createMessageErrorMessage(Message msg,
                                                      SocketConnection scon,
                                                      int minor)
Create OutputStream for sending Message Error Message
戻り値:
IIOPOutputStreamImpl

dispatchReceiveMessage

public static final void dispatchReceiveMessage(SocketConnection scon)
Create Message for receiving GIOP Message
戻り値:
Message

getPositionDifferenceForInputStream

public static final int getPositionDifferenceForInputStream(BufferPosition from,
                                                            BufferPosition to)
This methods is used by SocketInputStream and SocketOutputStream for getting difference between buffers.

getPositionDifferenceForOutputStream

public static final int getPositionDifferenceForOutputStream(BufferPosition from,
                                                             BufferPosition to)

getMessageTop

public final Message getMessageTop()
get top message

releaseResource

public void releaseResource()

releaseResource

public void releaseResource(boolean check_top)

releaseEncapsulateResource

public void releaseEncapsulateResource()

setExceptionToEnv

public void setExceptionToEnv(java.lang.Exception ex)

handleWritingException

public void handleWritingException(java.lang.Exception excp)
required from SocketConnection Return Exception
戻り値:
java.lang.Exception

handleReadingException

public void handleReadingException(java.lang.Exception excp)
required from SocketConnection Return Exception
戻り値:
java.lang.Exception

setException

public void setException(SystemException excp)
required from SocketConnection Return Exception
戻り値:
java.lang.Exception

setReplyMessage

public final void setReplyMessage(Message reply)
required from SocketConnection Set up receiver Message information to sender Message
パラメータ:
reply - Message
戻り値:
void

getReplyMessage

public final Message getReplyMessage(long timeout)
                              throws RemarshalException
required from SocketConnection Return Reply Message
戻り値:
Message

getResponseHandler

public final ResponseHandler getResponseHandler()
ResponseHandler

createReply

public final OutputStream createReply()
インタフェース ResponseHandler の記述:
Called by servant during a method invocation. The servant should call this method to create a reply marshal buffer if no exception occurred. Returns an OutputStream suitable for marshalling reply.
定義:
インタフェース ResponseHandler 内の createReply

createExceptionReply

public final OutputStream createExceptionReply()
インタフェース ResponseHandler の記述:
Called by servant during a method invocation. The servant should call this method to create a reply marshal buffer if a user exception occurred. Returns an OutputStream suitable for marshalling the exception ID and the user exception body.
定義:
インタフェース ResponseHandler 内の createExceptionReply

transactionCall

public void transactionCall(java.lang.Exception ex)
this method must be called by the thread that called sending_request.

createMessage

public static final Message createMessage(int version)
2000/06/01 add by osaki

putMessage

public static final void putMessage(Message nouse)

putReply

public void putReply()

preinvoke

public boolean preinvoke(RequestHandler handler)

getPropagationContext

public PropagationContext getPropagationContext()

postinvoke

public void postinvoke()

new_trans_request_id

public static int new_trans_request_id()

createNopReply

public final OutputStream createNopReply(int replystatus)

putUnexpectedUserException

public final void putUnexpectedUserException(java.lang.Exception e)

setSSLInfo

public void setSSLInfo(SSLInfo si)

getSSLInfo

public SSLInfo getSSLInfo()