Package org.apache.activemq.artemis.core.protocol.openwire.util

Class OpenWireUtil

java.lang.Object

org.apache.activemq.artemis.core.protocol.openwire.util.OpenWireUtil

public class OpenWireUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OpenWireUtil.OpenWireWildcardConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static WildcardConfiguration	OPENWIRE_WILDCARD
static String	SELECTOR_AWARE_OPTION

Constructor Summary

Constructors

Constructor	Description
OpenWireUtil()

Method Summary

Modifier and Type	Method	Description
static String	extractFilterStringOrNull(org.apache.activemq.command.ConsumerInfo info, org.apache.activemq.command.ActiveMQDestination openWireDest)
static org.apache.activemq.command.ActiveMQDestination	toAMQAddress(Message message, org.apache.activemq.command.ActiveMQDestination actualDestination)	We convert the core address to an ActiveMQ Destination.
static XidImpl	toXID(org.apache.activemq.command.TransactionId xaXid)
static XidImpl	toXID(org.apache.activemq.command.XATransactionId xaXid)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OPENWIRE_WILDCARD

public static final WildcardConfiguration OPENWIRE_WILDCARD

SELECTOR_AWARE_OPTION

public static final String SELECTOR_AWARE_OPTION

See Also:

Constant Field Values

Constructor Detail

OpenWireUtil

public OpenWireUtil()

Method Detail

extractFilterStringOrNull

public static String extractFilterStringOrNull(org.apache.activemq.command.ConsumerInfo info,
                                               org.apache.activemq.command.ActiveMQDestination openWireDest)

toAMQAddress

public static org.apache.activemq.command.ActiveMQDestination toAMQAddress(Message message,
                                                                           org.apache.activemq.command.ActiveMQDestination actualDestination)

We convert the core address to an ActiveMQ Destination. We use the actual address on the message rather than the destination set on the consumer because it maybe different and the JMS spec says that it should be what ever was set on publish/send so a divert or wildcard may mean thats its different to the destination subscribed to by the consumer

toXID

public static XidImpl toXID(org.apache.activemq.command.TransactionId xaXid)

toXID

public static XidImpl toXID(org.apache.activemq.command.XATransactionId xaXid)