public class MessageUtil extends Object
Modifier and Type | Field and Description |
---|---|
static org.apache.activemq.artemis.api.core.SimpleString |
CONNECTION_ID_PROPERTY_NAME |
static String |
CONNECTION_ID_PROPERTY_NAME_STRING |
static org.apache.activemq.artemis.api.core.SimpleString |
CORRELATIONID_HEADER_NAME |
static String |
CORRELATIONID_HEADER_NAME_STRING |
static org.apache.activemq.artemis.api.core.SimpleString |
JMS |
static org.apache.activemq.artemis.api.core.SimpleString |
JMS_ |
static org.apache.activemq.artemis.api.core.SimpleString |
JMSX |
static String |
JMSXDELIVERYCOUNT |
static String |
JMSXGROUPID |
static String |
JMSXGROUPSEQ |
static String |
JMSXUSERID |
static org.apache.activemq.artemis.api.core.SimpleString |
REPLYTO_HEADER_NAME |
static org.apache.activemq.artemis.api.core.SimpleString |
TYPE_HEADER_NAME |
static String |
TYPE_HEADER_NAME_STRING |
Constructor and Description |
---|
MessageUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
clearProperties(Message message) |
static int |
getIntProperty(Message message,
String name) |
static String |
getJMSCorrelationID(Message message) |
static byte[] |
getJMSCorrelationIDAsBytes(Message message) |
static org.apache.activemq.artemis.api.core.SimpleString |
getJMSReplyTo(Message message) |
static String |
getJMSType(Message message) |
static long |
getLongProperty(Message message,
String name) |
static Object |
getObjectProperty(Message message,
String name) |
static Set<String> |
getPropertyNames(Message message) |
static String |
getStringProperty(Message message,
String name) |
static boolean |
propertyExists(Message message,
String name) |
static void |
setIntProperty(Message message,
String name,
int value) |
static void |
setJMSCorrelationID(Message message,
String correlationID) |
static void |
setJMSCorrelationIDAsBytes(Message message,
byte[] correlationID) |
static void |
setJMSReplyTo(Message message,
org.apache.activemq.artemis.api.core.SimpleString dest) |
static void |
setJMSReplyTo(Message message,
String dest) |
static void |
setJMSType(Message message,
String type) |
static void |
setLongProperty(Message message,
String name,
long value) |
static void |
setObjectProperty(Message message,
String name,
Object value) |
static void |
setStringProperty(Message message,
String name,
String value) |
public static final String CORRELATIONID_HEADER_NAME_STRING
public static final org.apache.activemq.artemis.api.core.SimpleString CORRELATIONID_HEADER_NAME
public static final org.apache.activemq.artemis.api.core.SimpleString REPLYTO_HEADER_NAME
public static final String TYPE_HEADER_NAME_STRING
public static final org.apache.activemq.artemis.api.core.SimpleString TYPE_HEADER_NAME
public static final org.apache.activemq.artemis.api.core.SimpleString JMS
public static final org.apache.activemq.artemis.api.core.SimpleString JMSX
public static final org.apache.activemq.artemis.api.core.SimpleString JMS_
public static final String JMSXDELIVERYCOUNT
public static final String JMSXGROUPID
public static final String JMSXGROUPSEQ
public static final String JMSXUSERID
public static final String CONNECTION_ID_PROPERTY_NAME_STRING
public static final org.apache.activemq.artemis.api.core.SimpleString CONNECTION_ID_PROPERTY_NAME
public static byte[] getJMSCorrelationIDAsBytes(Message message)
public static final void setJMSCorrelationIDAsBytes(Message message, byte[] correlationID) throws org.apache.activemq.artemis.api.core.ActiveMQException
org.apache.activemq.artemis.api.core.ActiveMQException
public static org.apache.activemq.artemis.api.core.SimpleString getJMSReplyTo(Message message)
public static void setJMSReplyTo(Message message, org.apache.activemq.artemis.api.core.SimpleString dest)
public static void clearProperties(Message message)
Copyright © 2021 The Apache Software Foundation. All rights reserved.