public class StreamMessageUtil extends MessageUtil
CONNECTION_ID_PROPERTY_NAME, CORRELATIONID_HEADER_NAME, JMS, JMS_, JMSX, JMSXDELIVERYCOUNT, JMSXGROUPID, REPLYTO_HEADER_NAME, TYPE_HEADER_NAME
Constructor and Description |
---|
StreamMessageUtil() |
Modifier and Type | Method and Description |
---|---|
static boolean |
streamReadBoolean(Message message)
Method to read boolean values out of the Stream protocol existent on JMS Stream Messages
Throws IllegalStateException if the type was invalid
|
static byte |
streamReadByte(Message message) |
static Pair<Integer,Integer> |
streamReadBytes(Message message,
int remainingBytes,
byte[] value)
Utility for reading bytes out of streaming.
|
static char |
streamReadChar(Message message) |
static double |
streamReadDouble(Message message) |
static float |
streamReadFloat(Message message) |
static int |
streamReadInteger(Message message) |
static long |
streamReadLong(Message message) |
static Object |
streamReadObject(Message message) |
static short |
streamReadShort(Message message) |
static String |
streamReadString(Message message) |
clearProperties, getBodyBuffer, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSReplyTo, getJMSType, getPropertyNames, propertyExists, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSReplyTo, setJMSType
public static boolean streamReadBoolean(Message message)
message
- public static byte streamReadByte(Message message)
public static short streamReadShort(Message message)
public static char streamReadChar(Message message)
public static int streamReadInteger(Message message)
public static long streamReadLong(Message message)
public static float streamReadFloat(Message message)
public static double streamReadDouble(Message message)
public static Pair<Integer,Integer> streamReadBytes(Message message, int remainingBytes, byte[] value)
remainingBytes
- remaining Bytes from previous read. Send it to 0 if it was the first call for the messagemessage
- Copyright © 2015 The Apache Software Foundation. All rights reserved.