Package com.sun.corba.se.impl.protocol.giopmsgheaders

Class MessageBase

java.lang.Object

com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase

All Implemented Interfaces:

Message

Direct Known Subclasses:

Message_1_0, Message_1_1

public abstract class MessageBase
extends Object
implements Message

This class acts as the base class for the various GIOP message types. This also serves as a factory to create various message types. We currently support GIOP 1.0, 1.1 and 1.2 message types.

Author:

Ram Jeyaraman 05/14/2000

Field Summary

Fields

Modifier and Type	Field	Description
byte[]	giopHeader

Fields inherited from interface com.sun.corba.se.impl.protocol.giopmsgheaders.Message

CDR_ENC_VERSION, defaultBufferSize, FLAG_NO_FRAG_BIG_ENDIAN, GIOPBigEndian, GIOPBigMagic, GIOPCancelRequest, GIOPCloseConnection, GIOPFragment, GIOPLittleEndian, GIOPLittleMagic, GIOPLocateReply, GIOPLocateRequest, GIOPMessageError, GIOPMessageHeaderLength, GIOPReply, GIOPRequest, JAVA_ENC_VERSION, LITTLE_ENDIAN_BIT, MORE_FRAGMENTS_BIT, THREAD_POOL_TO_USE_MASK, TRAILING_TWO_BIT_BYTE_MASK

Constructor Summary

Constructors

Constructor	Description
MessageBase()

Method Summary

Modifier and Type	Method	Description
void	callback(MessageHandler handler)
static void	clearFlag(byte[] buf, int flag)	Clears a flag in the given buffer
static CancelRequestMessage	createCancelRequest(GIOPVersion gv, int request_id)
static Message	createCloseConnection(GIOPVersion gv)
static FragmentMessage	createFragmentMessage(GIOPVersion gv)
static LocateReplyMessage	createLocateReply(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, int locate_status, IOR ior)
static LocateRequestMessage	createLocateRequest(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, byte[] object_key)
static Message	createMessageError(GIOPVersion gv)
static ReplyMessage	createReply(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, int reply_status, ServiceContexts service_contexts, IOR ior)
static RequestMessage	createRequest(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, boolean response_expected, IOR ior, short addrDisp, String operation, ServiceContexts service_contexts, Principal requesting_principal)
ByteBuffer	getByteBuffer()
byte	getEncodingVersion()
static int	getRequestId(Message msg)
int	getThreadPoolToUse()
static Message	readGIOPBody(ORB orb, CorbaConnection connection, Message msg)
static MessageBase	readGIOPHeader(ORB orb, CorbaConnection connection)
static MessageBase	readGIOPMessage(ORB orb, CorbaConnection connection)
void	setByteBuffer(ByteBuffer byteBuffer)
void	setEncodingVersion(byte version)
static void	setFlag(ByteBuffer byteBuffer, int flag)	Set a flag in the given buffer (fragment bit, byte order bit, etc)
static String	typeToString(byte type)
static String	typeToString(int type)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.sun.corba.se.impl.protocol.giopmsgheaders.Message

createFragmentMessage, getGIOPVersion, getSize, getType, isLittleEndian, moreFragmentsToFollow, read, setSize, write

Field Details

giopHeader

public byte[] giopHeader

Constructor Details

MessageBase

public MessageBase()

Method Details

typeToString

public static String typeToString(int type)

typeToString

public static String typeToString(byte type)

readGIOPMessage

public static MessageBase readGIOPMessage(ORB orb,
 CorbaConnection connection)

readGIOPHeader

public static MessageBase readGIOPHeader(ORB orb,
 CorbaConnection connection)

readGIOPBody

public static Message readGIOPBody(ORB orb,
 CorbaConnection connection,
 Message msg)

createRequest

public static RequestMessage createRequest(ORB orb,
 GIOPVersion gv,
 byte encodingVersion,
 int request_id,
 boolean response_expected,
 IOR ior,
 short addrDisp,
 String operation,
 ServiceContexts service_contexts,
 Principal requesting_principal)

createReply

public static ReplyMessage createReply(ORB orb,
 GIOPVersion gv,
 byte encodingVersion,
 int request_id,
 int reply_status,
 ServiceContexts service_contexts,
 IOR ior)

createLocateRequest

public static LocateRequestMessage createLocateRequest(ORB orb,
 GIOPVersion gv,
 byte encodingVersion,
 int request_id,
 byte[] object_key)

createLocateReply

public static LocateReplyMessage createLocateReply(ORB orb,
 GIOPVersion gv,
 byte encodingVersion,
 int request_id,
 int locate_status,
 IOR ior)

createCancelRequest

public static CancelRequestMessage createCancelRequest(GIOPVersion gv,
 int request_id)

createCloseConnection

public static Message createCloseConnection(GIOPVersion gv)

createMessageError

public static Message createMessageError(GIOPVersion gv)

createFragmentMessage

public static FragmentMessage createFragmentMessage(GIOPVersion gv)

getRequestId

public static int getRequestId(Message msg)

setFlag

public static void setFlag(ByteBuffer byteBuffer,
 int flag)

Set a flag in the given buffer (fragment bit, byte order bit, etc)

clearFlag

public static void clearFlag(byte[] buf,
 int flag)

Clears a flag in the given buffer

callback

public void callback(MessageHandler handler)
              throws IOException

Specified by:

callback in interface Message

Throws:

IOException

getByteBuffer

public ByteBuffer getByteBuffer()

Specified by:

getByteBuffer in interface Message

setByteBuffer

public void setByteBuffer(ByteBuffer byteBuffer)

Specified by:

setByteBuffer in interface Message

getThreadPoolToUse

public int getThreadPoolToUse()

Specified by:

getThreadPoolToUse in interface Message

getEncodingVersion

public byte getEncodingVersion()

Specified by:

getEncodingVersion in interface Message

setEncodingVersion

public void setEncodingVersion(byte version)

Specified by:

setEncodingVersion in interface Message