public class AmqpSupport extends Object
Modifier and Type | Field and Description |
---|---|
static org.apache.qpid.proton.amqp.Symbol |
ANONYMOUS_RELAY |
static org.apache.qpid.proton.amqp.Symbol |
CONNECTION_OPEN_FAILED |
static org.apache.qpid.proton.amqp.Symbol |
CONTAINER_ID |
static org.apache.qpid.proton.amqp.Symbol |
COPY |
static org.apache.qpid.proton.amqp.Symbol |
DELAYED_DELIVERY |
static org.apache.qpid.proton.amqp.Symbol |
INVALID_FIELD |
static org.apache.qpid.proton.amqp.UnsignedLong |
JMS_SELECTOR_CODE |
static Object[] |
JMS_SELECTOR_FILTER_IDS |
static org.apache.qpid.proton.amqp.Symbol |
JMS_SELECTOR_NAME |
static org.apache.qpid.proton.amqp.Symbol |
LIFETIME_POLICY |
static org.apache.qpid.proton.amqp.UnsignedLong |
NO_LOCAL_CODE |
static Object[] |
NO_LOCAL_FILTER_IDS |
static org.apache.qpid.proton.amqp.Symbol |
NO_LOCAL_NAME |
static org.apache.qpid.proton.amqp.Symbol |
PLATFORM |
static org.apache.qpid.proton.amqp.Symbol |
PRODUCT |
static org.apache.qpid.proton.amqp.Symbol |
QUEUE_CAPABILITY |
static org.apache.qpid.proton.amqp.Symbol |
QUEUE_PREFIX |
static org.apache.qpid.proton.amqp.Symbol |
TEMP_QUEUE_CAPABILITY |
static org.apache.qpid.proton.amqp.Symbol |
TEMP_TOPIC_CAPABILITY |
static org.apache.qpid.proton.amqp.Symbol |
TOPIC_CAPABILITY |
static org.apache.qpid.proton.amqp.Symbol |
TOPIC_PREFIX |
static org.apache.qpid.proton.amqp.Symbol |
VERSION |
Constructor and Description |
---|
AmqpSupport() |
Modifier and Type | Method and Description |
---|---|
static boolean |
contains(org.apache.qpid.proton.amqp.Symbol[] symbols,
org.apache.qpid.proton.amqp.Symbol key)
Search for a given Symbol in a given array of Symbol object.
|
static ActiveMQDestination |
createDestination(Object endpoint)
Given an AMQP endpoint, deduce the appropriate ActiveMQDestination type and create
a new instance.
|
static Map.Entry<org.apache.qpid.proton.amqp.Symbol,org.apache.qpid.proton.amqp.DescribedType> |
findFilter(Map<org.apache.qpid.proton.amqp.Symbol,Object> filters,
Object[] filterIds)
Search for a particular filter using a set of known indentification values
in the Map of filters.
|
static org.apache.qpid.proton.amqp.Symbol |
getDestinationTypeSymbol(ActiveMQDestination destination)
Given an ActiveMQDestination return the proper Capability value for the concrete destination type.
|
static org.fusesource.hawtbuf.Buffer |
toBuffer(ByteBuffer data)
Conversion from Java ByteBuffer to a HawtBuf buffer.
|
static byte[] |
toBytes(long value)
Given a long value, convert it to a byte array for marshalling.
|
static long |
toLong(org.apache.qpid.proton.amqp.Binary value)
Converts a Binary value to a long assuming that the contained value is
stored in Big Endian encoding.
|
public static final org.apache.qpid.proton.amqp.UnsignedLong JMS_SELECTOR_CODE
public static final org.apache.qpid.proton.amqp.Symbol JMS_SELECTOR_NAME
public static final Object[] JMS_SELECTOR_FILTER_IDS
public static final org.apache.qpid.proton.amqp.UnsignedLong NO_LOCAL_CODE
public static final org.apache.qpid.proton.amqp.Symbol NO_LOCAL_NAME
public static final Object[] NO_LOCAL_FILTER_IDS
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 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 INVALID_FIELD
public static final org.apache.qpid.proton.amqp.Symbol CONTAINER_ID
public static final org.apache.qpid.proton.amqp.Symbol ANONYMOUS_RELAY
public static final org.apache.qpid.proton.amqp.Symbol DELAYED_DELIVERY
public static final org.apache.qpid.proton.amqp.Symbol QUEUE_PREFIX
public static final org.apache.qpid.proton.amqp.Symbol TOPIC_PREFIX
public static final org.apache.qpid.proton.amqp.Symbol CONNECTION_OPEN_FAILED
public static final org.apache.qpid.proton.amqp.Symbol PRODUCT
public static final org.apache.qpid.proton.amqp.Symbol VERSION
public static final org.apache.qpid.proton.amqp.Symbol PLATFORM
public static final org.apache.qpid.proton.amqp.Symbol COPY
public static final org.apache.qpid.proton.amqp.Symbol LIFETIME_POLICY
public AmqpSupport()
public static boolean contains(org.apache.qpid.proton.amqp.Symbol[] symbols, org.apache.qpid.proton.amqp.Symbol key)
symbols
- the set of Symbols to search.key
- the value to try and find in the Symbol array.public static Map.Entry<org.apache.qpid.proton.amqp.Symbol,org.apache.qpid.proton.amqp.DescribedType> findFilter(Map<org.apache.qpid.proton.amqp.Symbol,Object> filters, Object[] filterIds)
filters
- The filters map that should be searched.filterIds
- The aliases for the target filter to be located.public static org.fusesource.hawtbuf.Buffer toBuffer(ByteBuffer data)
data
- the ByteBuffer instance to convert.public static byte[] toBytes(long value)
value
- the value to convert.public static long toLong(org.apache.qpid.proton.amqp.Binary value)
value
- the Binary object whose payload is converted to a long.public static ActiveMQDestination createDestination(Object endpoint) throws AmqpProtocolException
endpoint
- the AMQP endpoint to construct an ActiveMQDestination from.AmqpProtocolException
- if an error occurs while deducing the destination type.public static org.apache.qpid.proton.amqp.Symbol getDestinationTypeSymbol(ActiveMQDestination destination)
destination
- The ActiveMQDestination whose capability is being requested.Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.