public abstract class MessageBase extends Object implements Message
Modifier and Type | Field and Description |
---|---|
byte[] |
giopHeader |
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 and Description |
---|
MessageBase() |
Modifier and Type | Method and 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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createFragmentMessage, getGIOPVersion, getSize, getType, isLittleEndian, moreFragmentsToFollow, read, setSize, write
public static String typeToString(int type)
public static String typeToString(byte type)
public static MessageBase readGIOPMessage(ORB orb, CorbaConnection connection)
public static MessageBase readGIOPHeader(ORB orb, CorbaConnection connection)
public static Message readGIOPBody(ORB orb, CorbaConnection connection, Message msg)
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)
public static ReplyMessage createReply(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, int reply_status, ServiceContexts service_contexts, IOR ior)
public static LocateRequestMessage createLocateRequest(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, byte[] object_key)
public static LocateReplyMessage createLocateReply(ORB orb, GIOPVersion gv, byte encodingVersion, int request_id, int locate_status, IOR ior)
public static CancelRequestMessage createCancelRequest(GIOPVersion gv, int request_id)
public static Message createCloseConnection(GIOPVersion gv)
public static Message createMessageError(GIOPVersion gv)
public static FragmentMessage createFragmentMessage(GIOPVersion gv)
public static int getRequestId(Message msg)
public static void setFlag(ByteBuffer byteBuffer, int flag)
public static void clearFlag(byte[] buf, int flag)
public void callback(MessageHandler handler) throws IOException
callback
in interface Message
IOException
public ByteBuffer getByteBuffer()
getByteBuffer
in interface Message
public void setByteBuffer(ByteBuffer byteBuffer)
setByteBuffer
in interface Message
public int getThreadPoolToUse()
getThreadPoolToUse
in interface Message
public byte getEncodingVersion()
getEncodingVersion
in interface Message
public void setEncodingVersion(byte version)
setEncodingVersion
in interface Message
Copyright © 2021 JBoss by Red Hat. All rights reserved.