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

Class OpenWireMessageConverter

java.lang.Object

org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter

public final class OpenWireMessageConverter
extends Object

Constructor Summary

Constructors

Constructor	Description
OpenWireMessageConverter()

Method Summary

Modifier and Type	Method	Description
static org.apache.activemq.command.MessageDispatch	createMessageDispatch(MessageReference reference, ICoreMessage message, org.apache.activemq.wireformat.WireFormat marshaller, AMQConsumer consumer, UUID serverNodeUUID)
static Message	inbound(org.apache.activemq.command.Message messageSend, org.apache.activemq.wireformat.WireFormat marshaller, CoreMessageObjectPools coreMessageObjectPools)
static byte	toCoreType(byte amqType)

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenWireMessageConverter

public OpenWireMessageConverter()

Method Detail

inbound

public static Message inbound(org.apache.activemq.command.Message messageSend,
                              org.apache.activemq.wireformat.WireFormat marshaller,
                              CoreMessageObjectPools coreMessageObjectPools)
                       throws Exception

Throws:

Exception

toCoreType

public static byte toCoreType(byte amqType)

createMessageDispatch

public static org.apache.activemq.command.MessageDispatch createMessageDispatch(MessageReference reference,
                                                                                ICoreMessage message,
                                                                                org.apache.activemq.wireformat.WireFormat marshaller,
                                                                                AMQConsumer consumer,
                                                                                UUID serverNodeUUID)
                                                                         throws IOException

Throws:

IOException