Package org.apache.activemq.transport.amqp.message

Class JMSMappingInboundTransformer

java.lang.Object

org.apache.activemq.transport.amqp.message.InboundTransformer

org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer

public class JMSMappingInboundTransformer
extends InboundTransformer

Field Summary

Fields inherited from class org.apache.activemq.transport.amqp.message.InboundTransformer

TRANSFORMER_JMS, TRANSFORMER_NATIVE, TRANSFORMER_RAW

Constructor Summary

Constructors

Constructor	Description
JMSMappingInboundTransformer()

Method Summary

Modifier and Type	Method	Description
static org.apache.activemq.command.ActiveMQMapMessage	createMapMessage(Map<String,Object> content)
static org.apache.activemq.command.ActiveMQObjectMessage	createObjectMessage(byte[] content, int offset, int length)
static org.apache.activemq.command.ActiveMQTextMessage	createTextMessage(String text)
protected org.apache.activemq.command.ActiveMQMessage	doTransform(EncodedMessage amqpMessage)
InboundTransformer	getFallbackTransformer()
String	getTransformerName()

Methods inherited from class org.apache.activemq.transport.amqp.message.InboundTransformer

populateMessage, transform

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSMappingInboundTransformer

public JMSMappingInboundTransformer()

Method Detail

getTransformerName

public String getTransformerName()

Specified by:

getTransformerName in class InboundTransformer

getFallbackTransformer

public InboundTransformer getFallbackTransformer()

Specified by:

getFallbackTransformer in class InboundTransformer

doTransform

protected org.apache.activemq.command.ActiveMQMessage doTransform(EncodedMessage amqpMessage)
                                                           throws Exception

Specified by:

doTransform in class InboundTransformer

Throws:

Exception

createTextMessage

public static org.apache.activemq.command.ActiveMQTextMessage createTextMessage(String text)

createObjectMessage

public static org.apache.activemq.command.ActiveMQObjectMessage createObjectMessage(byte[] content,
                                                                                    int offset,
                                                                                    int length)

createMapMessage

public static org.apache.activemq.command.ActiveMQMapMessage createMapMessage(Map<String,Object> content)
                                                                       throws JMSException

Throws:

JMSException