|
Sun Adapter for Websphere MQ API | |||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface IMessage
Represents a WebSphere MQ message. MQ messages that a WebSphere MQ eWay, in receive mode, passes to Java Collaborations, are objects that implement this interface.
For a Java Collaboration utilizing the WebSphere MQ eWay in non-receive (non-trigger) mode, the interface represents the Message portion of the eWay OTD.
Nested Class Summary | |
---|---|
static interface |
IMessage.MsgBody
The data (buffer) portion of a IMessage . |
static interface |
IMessage.MsgHeader
Represents the descriptor portion of a Message. |
Method Summary | |
---|---|
void |
assignEwayConfiguration(MQClientConfiguration cfg)
Associates an eWay configuration set to this message, for the purpose of giving users access to the eWay configuration. |
void |
assignSyncpointController(ISyncpointControl sc)
Associates a syncpoint controller to this message, for the purpose of giving users access to a restricted representation of the controller at a later time, in order to roll back or commit the message. |
void |
clearMessage()
Discards data in the message buffer and reset the data offset to zero. |
int |
getDataLength()
Reports the number of bytes of data remaining to be read in the message. |
int |
getDataOffset()
Returns the current position of the cursor within the message. |
EwayConfiguration |
getEwayConfiguration()
Obtains a reference to the configuration object of the eWay that is associated with the message. |
int |
getMessageLength()
Reports the total number of bytes in the stored message on the queue. |
IMessage.MsgBody |
getMsgBody()
Obtain a reference to the MsgBody object representing the Message's content. |
IMessage.MsgHeader |
getMsgHeader()
Obtains a reference to the MsgHeader object representing the message's descriptor. |
ISyncpointControl |
getSyncpointController()
Retrieves the syncpoint controller associated to this Message. |
int |
getTotalMessageLength()
If MQQueue.get() fails with a message-truncated error code, getTotalMessageLength() reports the total number of bytes in the stored message on the queue. |
boolean |
readBoolean()
Reads a (signed) byte from the present position in the message buffer. |
byte |
readByte()
Reads a byte from the present position in the message buffer. |
char |
readChar()
Reads a Unicode character from the present position in the message buffer. |
short |
readDecimal2()
Reads a 2-byte packed decimal number (-999 to 999). |
int |
readDecimal4()
Reads a 4-byte packed decimal number (-9999999 to 9999999). |
long |
readDecimal8()
Reads an 8-byte packed decimal number (-999999999999999 to 999999999999999). |
double |
readDouble()
Reads a double from the present position in the message buffer. |
float |
readFloat()
Reads a float from the present position in the message buffer. |
void |
readFully(byte[] buffer)
Fills the byte array with data from the message buffer. |
void |
readFully(byte[] buffer,
int offset,
int len)
Fills the len elements of the byte array b with data from the message buffer, starting at offset off. |
int |
readInt()
Reads an integer from the present position in the message buffer. |
short |
readInt2()
Equivalent to readshort(), but readInt2 is provided for cross-language MQSeries API compatibility. |
int |
readInt4()
Equivalent to readInt(), but readInt4 is provided for cross-language MQSeries API compatibility. |
long |
readInt8()
Equivalent to readlong(), but readInt8 is provided for cross-language MQSeries API compatibility. |
java.lang.String |
readLine()
Converts from the codeset defined in the characterSet member variable to Unicode, then reads in a line that has been terminated by \n, \r, \r\n, or EOF. |
long |
readLong()
Reads a long from the present position in the message buffer. |
java.lang.Object |
readObject()
Reads an object, its class, class signature, and the value of the non-transient and nonstatic fields of the class. |
short |
readShort()
Reads a short from the present position in the message buffer. |
java.lang.String |
readString(int length)
Reads a string in the codeset defined by the characterSet member variable. |
int |
readUInt2()
Equivalent to readUnsignedShort(), but readUInt2 is provided for cross-language MQSeries API compatibility. |
int |
readUnsignedByte()
Reads an unsigned byte from the present position in the message buffer. |
int |
readUnsignedShort()
Reads an unsigned short from the present position in the message buffer. |
java.lang.String |
readUTF()
Reads a UTF string, prefixed by a 2-byte length field, from the present position in the message buffer. |
void |
resizeBuffer(int size)
Clues the MQMessage object as to the size of buffer that may be necessary for subsequent get operations. |
void |
seek(int pos)
Relocates the cursor to the absolute position in the message buffer given by pos. |
void |
setDataOffset(int offset)
Relocates the cursor to the absolute position in the message buffer. |
void |
setVersion(int version)
Sets the version of the structure to be used. |
int |
skipBytes(int numberOfBytes)
Advances n bytes in the message buffer. |
void |
write(byte[] byteArray)
Writes a byte, an array of bytes, or a series of bytes into the message buffer at the present position. |
void |
write(byte[] byteArray,
int offset,
int len)
Writes a byte, an array of bytes, or a series of bytes into the message buffer at the present position. |
void |
write(int byteValue)
Writes a byte, an array of bytes, or a series of bytes into the message buffer at the present position. |
void |
writeBoolean(boolean boolValue)
Writes a Boolean into the message buffer at the present position. |
void |
writeByte(int byteValue)
Writes a byte into the message buffer at the present position. |
void |
writeBytes(java.lang.String stringValue)
Writes the string to the message buffer as a sequence of bytes. |
void |
writeChar(int unicodeChar)
Writes a Unicode character into the message buffer at the present position. |
void |
writeChars(java.lang.String str)
Writes a string as a sequence of Unicode characters into the message buffer at the current position. |
void |
writeDecimal2(short decimal2Value)
Writes a 2-byte packed decimal format number into the message buffer at the present position. |
void |
writeDecimal4(int decimal4Value)
Writes an 4-byte packed decimal format number into the message buffer at the present position. |
void |
writeDecimal8(long decimal8Value)
Writes an 8-byte packed decimal format number into the message buffer at the present position. |
void |
writeDouble(double doubleValue)
Writes a double into the message buffer at the present position. |
void |
writeFloat(float floatValue)
Writes a float into the message buffer at the present position. |
void |
writeInt(int intValue)
Writes an integer into the message buffer at the present position. |
void |
writeInt2(int shortValue)
Writes an integer into the message buffer at the present position. |
void |
writeInt4(int intValue)
Writes an integer into the message buffer at the present position. |
void |
writeInt8(long longValue)
Writes an integer into the message buffer at the present position. |
void |
writeLong(long longValue)
Writes a long into the message buffer at the present position. |
void |
writeObject(java.lang.Object objValue)
Writes the specified object, object class, class signature, and the values of the nontransient and non-static fields of the class and all its supertypes. |
void |
writeShort(int shortValue)
Writes a short into the message buffer at the present position. |
void |
writeString(java.lang.String strValue)
Writes a string into the message buffer at the present position, converting it to the codeset identified by the characterSet member variable. |
void |
writeUTF(java.lang.String utfString)
Writes a UTF string, prefixed by a 2-byte length field, into the message buffer at the present position. |
Methods inherited from interface com.stc.connector.persistence.bpel.PersistableData |
---|
persist, restore |
Method Detail |
---|
IMessage.MsgBody getMsgBody()
IMessage.MsgBody
IMessage.MsgHeader getMsgHeader()
Message.MsgHeader
EwayConfiguration getEwayConfiguration()
void assignSyncpointController(ISyncpointControl sc)
sc
- The syncpoint controller.void assignEwayConfiguration(MQClientConfiguration cfg)
cfg
- eWay configuration objectISyncpointControl getSyncpointController()
null
.
ISyncpointControl
- Returns the syncpoint controller.
int getTotalMessageLength()
int
- Returns the total message length.
MQMessage.getTotalMessageLength()
int getMessageLength() throws java.io.IOException
int
- Returns the total number of bytes in the
stored message on the queue
java.io.IOException
- Thrown when an error occurs.MQMessage.getMessageLength()
int getDataLength() throws java.io.IOException
int
- Returns the number of bytes of data remaining
to be read in the message.
java.io.IOException
- Thrown when an error occurs.MQMessage.getDataLength()
void seek(int pos) throws java.io.IOException
pos
- Gives the absolute position in the message buffer.
java.io.IOException
- Thrown when an error occurs.MQMessage.seek(int)
void setDataOffset(int offset) throws java.io.IOException
offset
- Gives the absolute position in the message buffer.
java.io.IOException
- Thrown when an error occurs.MQMessage.setDataOffset(int)
int getDataOffset() throws java.io.IOException
int
- Returns the current cursor position.
java.io.IOException
- Thrown when an error occurs.MQMessage.getDataOffset()
void clearMessage() throws java.io.IOException
java.io.IOException
- Thrown when an error occurs.MQMessage.clearMessage()
void resizeBuffer(int size) throws java.io.IOException
size
- The size of the buffer.
java.io.IOException
- Thrown when an error occurs.MQMessage.resizeBuffer(int)
boolean readBoolean() throws java.io.EOFException, java.io.IOException
Boolean
- Returns a byte from the
current position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readBoolean()
byte readByte() throws java.io.IOException, java.io.EOFException
byte
- Returns a byte from the
current position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readByte()
char readChar() throws java.io.EOFException, java.io.IOException
char
- Returns a unicode character from the
current position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readChar()
double readDouble() throws java.io.EOFException, java.io.IOException
double
- Returns a double from the
current position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readDouble()
float readFloat() throws java.io.EOFException, java.io.IOException
float
- Returns a float from the present
position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readFloat()
void readFully(byte[] buffer) throws java.io.EOFException, java.io.IOException
buffer
- Data from the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readFully(byte[])
void readFully(byte[] buffer, int offset, int len) throws java.io.EOFException, java.io.IOException
buffer
- Fills the byte array with data from the
message buffer.offset
- The offset at which the fill starts.len
- Fills len elements of the byte array
with data from the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readFully(byte[], int, int)
int readInt() throws java.io.EOFException, java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL reads a big-endian integer, a value of MQC.MQENC_INTEGER_REVERSED reads a little-endian integer.
int
- Returns an integer from the current
position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readInt()
int readInt4() throws java.io.EOFException, java.io.IOException
int
- Returns an integer from the current
position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readInt4()
java.lang.String readLine() throws java.io.IOException
String
- Returns the unicode characterSet.
java.io.IOException
- Thrown when an error occurs.MQMessage.readLine()
long readLong() throws java.io.EOFException, java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL reads a big-endian long, a value of MQC.MQENC_INTEGER_REVERSED reads a little-endian long.
long
- Returns a long from the present position
in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readLong()
long readInt8() throws java.io.EOFException, java.io.IOException
long
- Returns a long from the present position
in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readInt8()
java.lang.Object readObject() throws java.lang.ClassNotFoundException, java.io.InvalidClassException, java.io.StreamCorruptedException, java.io.OptionalDataException, java.io.IOException
object
- Returns an object, its class, class
signature, and vield value.
java.lang.ClassNotFoundException
- Thrown when an error occurs.
java.io.InvalidClassException
- Thrown when an error occurs.
java.io.StreamCorruptedException
- Thrown when an error occurs.
java.io.OptionalDataException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readObject()
short readShort() throws java.io.EOFException, java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL reads a big-endian short, a value of MQC.MQENC_INTEGER_REVERSED reads a little-endian short.
short
- Returns a short from the present position
in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readShort()
short readInt2() throws java.io.EOFException, java.io.IOException
short
- Returns a short from the present position in the
message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readInt2()
java.lang.String readUTF() throws java.io.IOException
String
- Returns a UTF String, beginning with a 2-byte
length field, from the present position in the message buffer.
java.io.IOException
- Thrown when an error occurs.MQMessage.readUTF()
int readUnsignedByte() throws java.io.EOFException, java.io.IOException
int
- Returns an unsigned byte from the present
position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readUnsignedByte()
int readUnsignedShort() throws java.io.EOFException, java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL reads a big-endian unsigned short, a value of MQC.MQENC_INTEGER_REVERSED reads a little-endian unsigned short.
int
- Returns an unsigned byte from the present
position in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readUnsignedShort()
int readUInt2() throws java.io.EOFException, java.io.IOException
int
- Returns an unsigned int from the present position
in the message buffer.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readUInt2()
java.lang.String readString(int length) throws java.io.EOFException, java.io.IOException
length
- The number of characters to read (not the same as the number of bytes).
String
- Returns the Unicode value of the string in
the codeset defined by the characterSet member variable.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readString(int)
short readDecimal2() throws java.io.EOFException, java.io.IOException
short
- Returns a 2-byte packed decimal number.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readDecimal2()
int readDecimal4() throws java.io.EOFException, java.io.IOException
A value of MQC.MQENC_DECIMAL_NORMAL reads a big-endian packed decimal number, and a value of MQC.MQENC_DECIMAL_REVERSED reads a little-endian packed decimal number.
int
- Returns a 4-byte packed decimal number.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readDecimal4()
long readDecimal8() throws java.io.EOFException, java.io.IOException
A value of MQC.MQENC_DECIMAL_NORMAL reads a big-endian packed decimal number, and a value of MQC.MQENC_DECIMAL_REVERSED reads a little-endian packed decimal number.
long
- Returns an 8-byte packed decimal number.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.readDecimal8()
void setVersion(int version) throws MQException
This method is used when it is necessary to force a client to use a version 1 structure when connected to a queue manager that is able to handling version 2 structures. In all other situations, the client determines the correct version by querying the queue manager's capabilities.
version
- The version number.
MQException
- Thrown when an error occurs.MQMD.setVersion(int)
int skipBytes(int numberOfBytes) throws java.io.EOFException, java.io.IOException
numberOfBytes
- Move forward n bytes in the message buffer.
int
- Returns the number of bytes skipped, which is always n.
java.io.EOFException
- Thrown when an error occurs.
java.io.IOException
- Thrown when an error occurs.MQMessage.skipBytes(int)
void write(int byteValue) throws java.io.IOException
byteValue
- The number of characters to read (not the same as the number of bytes).
java.io.IOException
- Thrown when an error occurs.MQMessage.write(int)
void write(byte[] byteArray) throws java.io.IOException
byteArray
- The number of characters to read (not the same as the number of bytes).
java.io.IOException
- Thrown when an error occurs.MQMessage.write(byte[])
void write(byte[] byteArray, int offset, int len) throws java.io.IOException
byteArray
- The number of characters to read (not the same as the number of bytes).offset
- The offset in the array.len
- The number of bytes to be written.
java.io.IOException
- Thrown when an error occurs.MQMessage.write(byte[], int, int)
void writeBoolean(boolean boolValue) throws java.io.IOException
boolValue
- The Boolean value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeBoolean(boolean)
void writeByte(int byteValue) throws java.io.IOException
byteValue
- The byte value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeByte(int)
void writeBytes(java.lang.String stringValue) throws java.io.IOException
stringValue
- The String value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeBytes(String)
void writeChar(int unicodeChar) throws java.io.IOException
unicodeChar
- The Unicode character value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeChar(int)
void writeChars(java.lang.String str) throws java.io.IOException
str
- The String value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeChars(String)
void writeDouble(double doubleValue) throws java.io.IOException
A value of MQC.MQENC_FLOAT_IEEE_NORMAL or MQC.MQENC_FLOAT_IEEE_REVERSED write IEEE standard floats in big-endian and little-endian formats respectively. A value of MQC.MQENC_FLOAT_S390 writes a System/390 format floating point number. The range of IEEE doubles is greater than the range of S/390 double precision floating point numbers. Very large numbers cannot be converted.
doubleValue
- The number of characters to read (not the same as the number of bytes).
java.io.IOException
- Thrown when an error occurs.MQMessage.writeDouble(double)
void writeFloat(float floatValue) throws java.io.IOException
A Value of MQC.MQENC_FLOAT_IEEE_NORMAL or MQC.MQENC_FLOAT_IEEE_REVERSED write IEEE standard floats in big-endian and little-endian formats respectively. A value of MQC.MQENC_FLOAT_S390 writes a System/390 format floating point number.
floatValue
- The float value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeFloat(float)
void writeInt(int intValue) throws java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL writes a big-endian integer. A value of MQC.MQENC_INTEGER_REVERSED writes a little-endian integer.
intValue
- The int value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeInt(int)
void writeInt4(int intValue) throws java.io.IOException
intValue
- The int value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeInt4(int)
void writeLong(long longValue) throws java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL writes a big-endian long. A value of MQC.MQENC_INTEGER_REVERSED writes a little-endian long.
longValue
- The long value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeLong(long)
void writeInt8(long longValue) throws java.io.IOException
longValue
- The long value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeInt8(long)
void writeObject(java.lang.Object objValue) throws java.io.IOException
objValue
- The object value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeObject(Object)
void writeShort(int shortValue) throws java.io.IOException
A value of MQC.MQENC_INTEGER_NORMAL writes a big-endian short. A value of MQC.MQENC_INTEGER_REVERSED writes a little-endian short.
shortValue
- The short value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeShort(int)
void writeInt2(int shortValue) throws java.io.IOException
shortValue
- The short value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeInt2(int)
void writeDecimal2(short decimal2Value) throws java.io.IOException
A value of MQC.MQENC_DECIMAL_NORMAL writes a big-endian packed decimal. A value of MQC.MQENC_DECIMAL_REVERSED writes a little-endian packed decimal.
decimal2Value
- The 2-byte decimal value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeDecimal2(short)
void writeDecimal4(int decimal4Value) throws java.io.IOException
A value of MQC.MQENC_DECIMAL_NORMAL writes a big-endian packed decimal. A value of MQC.MQENC_DECIMAL_REVERSED writes a little-endian packed decimal.
decimal4Value
- The 4-byte decimal value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeDecimal4(int)
void writeDecimal8(long decimal8Value) throws java.io.IOException
A value of MQC.MQENC_DECIMAL_NORMAL writes a big-endian packed decimal. A value of MQC.MQENC_DECIMAL_REVERSED writes a little-endian packed decimal.
decimal8Value
- The 8-byte decimal value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeDecimal8(long)
void writeUTF(java.lang.String utfString) throws java.io.IOException
utfString
- The String value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeUTF(String)
void writeString(java.lang.String strValue) throws java.io.IOException
strValue
- The String value.
java.io.IOException
- Thrown when an error occurs.MQMessage.writeString(String)
|
Sun Adapter for Websphere MQ API | |||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |