public class JMSMappingOutboundTransformer extends OutboundTransformer
Modifier and Type | Field and Description |
---|---|
static org.apache.qpid.proton.amqp.Symbol |
JMS_DEST_TYPE_MSG_ANNOTATION |
static org.apache.qpid.proton.amqp.Symbol |
JMS_REPLY_TO_TYPE_MSG_ANNOTATION |
static org.apache.qpid.proton.amqp.Symbol |
LEGACY_JMS_DEST_TYPE_MSG_ANNOTATION |
static org.apache.qpid.proton.amqp.Symbol |
LEGACY_JMS_REPLY_TO_TYPE_MSG_ANNOTATION |
static String |
LEGACY_QUEUE_TYPE |
static String |
LEGACY_TEMP_QUEUE_TYPE |
static String |
LEGACY_TEMP_TOPIC_TYPE |
static String |
LEGACY_TOPIC_TYPE |
static byte |
QUEUE_TYPE |
static byte |
TEMP_QUEUE_TYPE |
static byte |
TEMP_TOPIC_TYPE |
static byte |
TOPIC_TYPE |
Constructor and Description |
---|
JMSMappingOutboundTransformer(JMSVendor vendor) |
Modifier and Type | Method and Description |
---|---|
org.apache.qpid.proton.message.ProtonJMessage |
convert(javax.jms.Message msg)
Perform the conversion between JMS Message and Proton Message without
re-encoding it to array.
|
getPrefixVendor, getVendor, setPrefixVendor, setVendor
public static final org.apache.qpid.proton.amqp.Symbol JMS_DEST_TYPE_MSG_ANNOTATION
public static final org.apache.qpid.proton.amqp.Symbol JMS_REPLY_TO_TYPE_MSG_ANNOTATION
public static final byte QUEUE_TYPE
public static final byte TOPIC_TYPE
public static final byte TEMP_QUEUE_TYPE
public static final byte TEMP_TOPIC_TYPE
public static final org.apache.qpid.proton.amqp.Symbol LEGACY_JMS_DEST_TYPE_MSG_ANNOTATION
public static final org.apache.qpid.proton.amqp.Symbol LEGACY_JMS_REPLY_TO_TYPE_MSG_ANNOTATION
public static final String LEGACY_QUEUE_TYPE
public static final String LEGACY_TOPIC_TYPE
public static final String LEGACY_TEMP_QUEUE_TYPE
public static final String LEGACY_TEMP_TOPIC_TYPE
public JMSMappingOutboundTransformer(JMSVendor vendor)
public org.apache.qpid.proton.message.ProtonJMessage convert(javax.jms.Message msg) throws javax.jms.JMSException, UnsupportedEncodingException
msg
- Exception
javax.jms.JMSException
UnsupportedEncodingException
Copyright © 2016 The Apache Software Foundation. All rights reserved.