org.apache.synapse.transport.amqp

Class AMQPTransportMessage

java.lang.Object

org.apache.synapse.transport.amqp.AMQPTransportMessage

public class AMQPTransportMessage
extends Object

Represent a AMQP message transfer between the broker and the consumer/producer.

Constructor Summary

Constructors

Constructor and Description
AMQPTransportMessage(com.rabbitmq.client.BasicProperties basicProperties, byte[] message)
AMQPTransportMessage(com.rabbitmq.client.QueueingConsumer.Delivery delivery)

Method Summary

Modifier and Type	Method and Description
String	getAppId()
byte[]	getBody()
String	getClusterId()
String	getContentEncoding()
String	getContentType()
String	getCorrelationId()
com.rabbitmq.client.QueueingConsumer.Delivery	getDelivery()
Integer	getDeliveryMode()
com.rabbitmq.client.Envelope	getEnvelope()
String	getExpiration()
Map<String,Object>	getHeaders()
String	getMessageId()
Integer	getPriority()
String	getReplyTo()
String	getSoapAction()
Date	getTimestamp()
String	getType()
String	getUserId()

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportMessage

public AMQPTransportMessage(com.rabbitmq.client.QueueingConsumer.Delivery delivery)

AMQPTransportMessage

public AMQPTransportMessage(com.rabbitmq.client.BasicProperties basicProperties,
                            byte[] message)

Method Detail

getSoapAction

public String getSoapAction()

getMessageId

public String getMessageId()

getContentType

public String getContentType()

getContentEncoding

public String getContentEncoding()

getDeliveryMode

public Integer getDeliveryMode()

getPriority

public Integer getPriority()

getCorrelationId

public String getCorrelationId()

getReplyTo

public String getReplyTo()

getExpiration

public String getExpiration()

getTimestamp

public Date getTimestamp()

getType

public String getType()

getUserId

public String getUserId()

getAppId

public String getAppId()

getClusterId

public String getClusterId()

getHeaders

public Map<String,Object> getHeaders()

getBody

public byte[] getBody()

getDelivery

public com.rabbitmq.client.QueueingConsumer.Delivery getDelivery()

getEnvelope

public com.rabbitmq.client.Envelope getEnvelope()