public abstract class InboundTransformer extends Object
Modifier and Type | Field and Description |
---|---|
static String |
TRANSFORMER_JMS |
static String |
TRANSFORMER_NATIVE |
static String |
TRANSFORMER_RAW |
Constructor and Description |
---|
InboundTransformer(JMSVendor vendor) |
Modifier and Type | Method and Description |
---|---|
int |
getDefaultDeliveryMode() |
int |
getDefaultPriority() |
long |
getDefaultTtl() |
abstract InboundTransformer |
getFallbackTransformer() |
String |
getPrefixVendor() |
abstract String |
getTransformerName() |
JMSVendor |
getVendor() |
protected void |
populateMessage(Message jms,
org.apache.qpid.proton.message.Message amqp) |
void |
setDefaultDeliveryMode(int defaultDeliveryMode) |
void |
setDefaultPriority(int defaultPriority) |
void |
setDefaultTtl(long defaultTtl) |
void |
setPrefixVendor(String prefixVendor) |
void |
setVendor(JMSVendor vendor) |
abstract Message |
transform(EncodedMessage amqpMessage) |
public static final String TRANSFORMER_NATIVE
public static final String TRANSFORMER_RAW
public static final String TRANSFORMER_JMS
public InboundTransformer(JMSVendor vendor)
public abstract Message transform(EncodedMessage amqpMessage) throws Exception
Exception
public abstract String getTransformerName()
public abstract InboundTransformer getFallbackTransformer()
public int getDefaultDeliveryMode()
public void setDefaultDeliveryMode(int defaultDeliveryMode)
public int getDefaultPriority()
public void setDefaultPriority(int defaultPriority)
public long getDefaultTtl()
public void setDefaultTtl(long defaultTtl)
public String getPrefixVendor()
public void setPrefixVendor(String prefixVendor)
protected void populateMessage(Message jms, org.apache.qpid.proton.message.Message amqp) throws Exception
Exception
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.