public class StreamMessageUtil extends MessageUtil
CONNECTION_ID_PROPERTY_NAME, CORRELATIONID_HEADER_NAME, JMS, JMS_, JMSX, JMSXDELIVERYCOUNT, JMSXGROUPID, JMSXGROUPSEQ, JMSXUSERID, REPLYTO_HEADER_NAME, TYPE_HEADER_NAME
Constructor and Description |
---|
StreamMessageUtil() |
Modifier and Type | Method and Description |
---|---|
static boolean |
streamReadBoolean(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
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(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static org.apache.activemq.artemis.api.core.Pair<Integer,Integer> |
streamReadBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff,
int remainingBytes,
byte[] value)
Utility for reading bytes out of streaming.
|
static char |
streamReadChar(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static double |
streamReadDouble(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static float |
streamReadFloat(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static int |
streamReadInteger(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static long |
streamReadLong(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static Object |
streamReadObject(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static short |
streamReadShort(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
static String |
streamReadString(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff) |
clearProperties, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSReplyTo, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getStringProperty, propertyExists, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSReplyTo, setJMSReplyTo, setJMSType, setLongProperty, setObjectProperty, setStringProperty
public static boolean streamReadBoolean(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
buff
- public static byte streamReadByte(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static short streamReadShort(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static char streamReadChar(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static int streamReadInteger(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static long streamReadLong(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static float streamReadFloat(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static double streamReadDouble(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static String streamReadString(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
public static org.apache.activemq.artemis.api.core.Pair<Integer,Integer> streamReadBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff, int remainingBytes, byte[] value)
remainingBytes
- remaining Bytes from previous read. Send it to 0 if it was the first call for the messagebuff
- public static Object streamReadObject(org.apache.activemq.artemis.api.core.ActiveMQBuffer buff)
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.