public final class AmqpMessageSupport extends Object
Modifier and Type | Field and Description |
---|---|
static String |
JMS_AMQP_REPLY_TO_GROUP_ID |
static String |
JMS_AMQP_TTL |
static String |
JMS_AMQP_TYPED_ENCODING |
static String |
JMS_APP_CORRELATION_ID
Attribute used to mark the Application defined correlation Id that has been
set for the message.
|
static byte |
JMS_BYTES_MESSAGE
Value mapping for JMS_MSG_TYPE which indicates the message is a JMS BytesMessage
which has a body that consists of raw bytes.
|
static byte |
JMS_MAP_MESSAGE
Value mapping for JMS_MSG_TYPE which indicates the message is a JMS MapMessage
which has an Map instance serialized in its message body.
|
static byte |
JMS_MESSAGE
Value mapping for JMS_MSG_TYPE which indicates the message is a generic JMS Message
which has no body.
|
static String |
JMS_MSG_TYPE
Attribute used to mark the class type of JMS message that a particular message
instance represents, used internally by the client.
|
static byte |
JMS_OBJECT_MESSAGE
Value mapping for JMS_MSG_TYPE which indicates the message is a JMS ObjectMessage
which has an Object value serialized in its message body.
|
static byte |
JMS_STREAM_MESSAGE
Value mapping for JMS_MSG_TYPE which indicates the message is a JMS StreamMessage
which has a body that is a structured collection of primitives values.
|
static byte |
JMS_TEXT_MESSAGE
Value mapping for JMS_MSG_TYPE which indicates the message is a JMS TextMessage
which has a body that contains a UTF-8 encoded String.
|
static String |
LEGACY_QUEUE_ATTRIBUTE |
static String |
LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL_NAME |
static String |
LEGACY_TEMPORARY_ATTRIBUTE |
static String |
LEGACY_TO_TYPE_MSG_ANNOTATION_SYMBOL_NAME |
static String |
LEGACY_TOPIC_ATTRIBUTE |
static String |
OCTET_STREAM_CONTENT_TYPE
Content type used to mark Data sections as containing arbitrary bytes.
|
static String |
SERIALIZED_JAVA_OBJECT_CONTENT_TYPE
Content type used to mark Data sections as containing a serialized java object.
|
Constructor and Description |
---|
AmqpMessageSupport() |
Modifier and Type | Method and Description |
---|---|
static Object |
getMessageAnnotation(String key,
org.apache.qpid.proton.message.Message message)
Safe way to access message annotations which will check internal structure and
either return the annotation if it exists or null if the annotation or any annotations
are present.
|
static org.apache.qpid.proton.amqp.Symbol |
getSymbol(String key)
Lookup and return the correct Proton Symbol instance based on the given key.
|
static boolean |
isContentType(String contentType,
org.apache.qpid.proton.message.Message message)
Check whether the content-type field of the properties section (if present) in
the given message matches the provided string (where null matches if there is
no content type present.
|
public static final String JMS_APP_CORRELATION_ID
public static final String JMS_MSG_TYPE
public static final byte JMS_MESSAGE
public static final byte JMS_OBJECT_MESSAGE
public static final byte JMS_MAP_MESSAGE
public static final byte JMS_BYTES_MESSAGE
public static final byte JMS_STREAM_MESSAGE
public static final byte JMS_TEXT_MESSAGE
public static final String JMS_AMQP_TTL
public static final String JMS_AMQP_REPLY_TO_GROUP_ID
public static final String JMS_AMQP_TYPED_ENCODING
public static final String SERIALIZED_JAVA_OBJECT_CONTENT_TYPE
public static final String OCTET_STREAM_CONTENT_TYPE
public static final String LEGACY_TO_TYPE_MSG_ANNOTATION_SYMBOL_NAME
public static final String LEGACY_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL_NAME
public static final String LEGACY_QUEUE_ATTRIBUTE
public static final String LEGACY_TOPIC_ATTRIBUTE
public static final String LEGACY_TEMPORARY_ATTRIBUTE
public static org.apache.qpid.proton.amqp.Symbol getSymbol(String key)
key
- the String value name of the Symbol to locate.public static Object getMessageAnnotation(String key, org.apache.qpid.proton.message.Message message)
key
- the String key to use to lookup an annotation.message
- the AMQP message object that is being examined.public static boolean isContentType(String contentType, org.apache.qpid.proton.message.Message message)
contentType
- content type string to compare against, or null if nonemessage
- the AMQP message object that is being examined.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.