public class AmqpDestinationHelper extends Object
Modifier and Type | Field and Description |
---|---|
static AmqpDestinationHelper |
INSTANCE |
static String |
JMS_DEST_TYPE_MSG_ANNOTATION_SYMBOL_NAME |
static String |
JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL_NAME |
static org.apache.qpid.proton.amqp.Symbol |
QUEUE_CAPABILITY |
static byte |
QUEUE_TYPE |
static org.apache.qpid.proton.amqp.Symbol |
TEMP_QUEUE_CAPABILITY |
static byte |
TEMP_QUEUE_TYPE |
static org.apache.qpid.proton.amqp.Symbol |
TEMP_TOPIC_CAPABILITY |
static byte |
TEMP_TOPIC_TYPE |
static org.apache.qpid.proton.amqp.Symbol |
TOPIC_CAPABILITY |
static byte |
TOPIC_TYPE |
Constructor and Description |
---|
AmqpDestinationHelper() |
Modifier and Type | Method and Description |
---|---|
String |
getDestinationAddress(JmsDestination destination,
AmqpConnection conn) |
JmsDestination |
getJmsDestination(AmqpJmsMessageFacade message,
JmsDestination consumerDestination)
Decode the provided To address, type description, and consumer destination
information such that an appropriate Destination object can be returned.
|
JmsDestination |
getJmsReplyTo(AmqpJmsMessageFacade message,
JmsDestination consumerDestination) |
void |
setReplyToAddressFromDestination(AmqpJmsMessageFacade message,
JmsDestination destination) |
void |
setToAddressFromDestination(AmqpJmsMessageFacade message,
JmsDestination destination) |
org.apache.qpid.proton.amqp.Symbol |
toTypeCapability(JmsDestination destination)
Return the appropriate type capability to describe the given Destination.
|
public static final AmqpDestinationHelper INSTANCE
public static final String JMS_DEST_TYPE_MSG_ANNOTATION_SYMBOL_NAME
public static final String JMS_REPLY_TO_TYPE_MSG_ANNOTATION_SYMBOL_NAME
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 QUEUE_CAPABILITY
public static final org.apache.qpid.proton.amqp.Symbol TOPIC_CAPABILITY
public static final org.apache.qpid.proton.amqp.Symbol TEMP_QUEUE_CAPABILITY
public static final org.apache.qpid.proton.amqp.Symbol TEMP_TOPIC_CAPABILITY
public JmsDestination getJmsDestination(AmqpJmsMessageFacade message, JmsDestination consumerDestination)
message
- The message that holds the addressing information.consumerDestination
- The destination that the consumer is subscribed to.public JmsDestination getJmsReplyTo(AmqpJmsMessageFacade message, JmsDestination consumerDestination)
public void setToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination)
public void setReplyToAddressFromDestination(AmqpJmsMessageFacade message, JmsDestination destination)
public String getDestinationAddress(JmsDestination destination, AmqpConnection conn)
public org.apache.qpid.proton.amqp.Symbol toTypeCapability(JmsDestination destination)
destination
- The Destination to examine for the destination type capability.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.