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

Constructor Summary

Constructors

Constructor and Description
OpenWireUtil()

Method Summary

Modifier and Type	Method and Description
static String	convertWildcard(String physicalName)
static org.apache.activemq.artemis.api.core.ActiveMQBuffer	toActiveMQBuffer(org.apache.activemq.util.ByteSequence bytes)
static org.apache.activemq.command.ActiveMQDestination	toAMQAddress(ServerMessage message, org.apache.activemq.command.ActiveMQDestination actualDestination) We convert the core address to an ActiveMQ Destination.
static org.apache.activemq.artemis.api.core.SimpleString	toCoreAddress(org.apache.activemq.command.ActiveMQDestination dest)
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

Constructor Detail

OpenWireUtil

public OpenWireUtil()

Method Detail

toActiveMQBuffer

public static org.apache.activemq.artemis.api.core.ActiveMQBuffer toActiveMQBuffer(org.apache.activemq.util.ByteSequence bytes)

toCoreAddress

public static org.apache.activemq.artemis.api.core.SimpleString toCoreAddress(org.apache.activemq.command.ActiveMQDestination dest)

toAMQAddress

public static org.apache.activemq.command.ActiveMQDestination toAMQAddress(ServerMessage 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

convertWildcard

public static String convertWildcard(String physicalName)

toXID

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

toXID

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