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

Class OpenWireMessageConverter

java.lang.Object

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

All Implemented Interfaces:

MessageConverter

public class OpenWireMessageConverter
extends Object
implements MessageConverter

Field Summary

Fields

Modifier and Type	Field and Description
static String	AMQ_MSG_DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY
static String	AMQ_PREFIX

Constructor Summary

Constructors

Constructor and Description
OpenWireMessageConverter(org.apache.activemq.wireformat.WireFormat marshaller)

Method Summary

Modifier and Type	Method and Description
static org.apache.activemq.command.MessageDispatch	createMessageDispatch(MessageReference reference, ServerMessage message, AMQConsumer consumer)
ServerMessage	inbound(Object message)
Object	outbound(ServerMessage message, int deliveryCount)
static byte	toCoreType(byte amqType)

Methods inherited from class java.lang.Object

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

Field Detail

AMQ_PREFIX

public static final String AMQ_PREFIX

See Also:

Constant Field Values

AMQ_MSG_DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY

public static final String AMQ_MSG_DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY

See Also:

Constant Field Values

Constructor Detail

OpenWireMessageConverter

public OpenWireMessageConverter(org.apache.activemq.wireformat.WireFormat marshaller)

Method Detail

outbound

public Object outbound(ServerMessage message,
                       int deliveryCount)

Specified by:

outbound in interface MessageConverter

inbound

public ServerMessage inbound(Object message)
                      throws Exception

Specified by:

inbound in interface MessageConverter

Throws:

Exception

toCoreType

public static byte toCoreType(byte amqType)

createMessageDispatch

public static org.apache.activemq.command.MessageDispatch createMessageDispatch(MessageReference reference,
                                                                                ServerMessage message,
                                                                                AMQConsumer consumer)
                                                                         throws IOException,
                                                                                javax.jms.JMSException

Throws:

IOException

javax.jms.JMSException