public class RabbitMQMessage extends Object
Constructor and Description |
---|
RabbitMQMessage() |
Modifier and Type | Method and Description |
---|---|
byte[] |
getBody()
Get body of the message
|
String |
getContentEncoding()
Get content encoding of the message
|
String |
getContentType()
Get content type of the message
|
String |
getCorrelationId()
Get correlation id of the message
|
long |
getDeliveryTag()
get delivery tag of the message set by transport
|
Map<String,Object> |
getHeaders()
get all headers of the message as a map
|
String |
getMessageId()
Get identifier of the message
|
String |
getReplyTo()
get header 'Replyto' of RabbitMQ
|
String |
getSoapAction()
Get soap action message bares
|
void |
setBody(byte[] body)
set body of the message
|
void |
setContentEncoding(String contentEncoding)
Set content encoding for the message
|
void |
setContentType(String contentType)
Set content type for the message
|
void |
setCorrelationId(String correlationId)
Set correlation id of the message
|
void |
setDeliveryTag(long deliveryTag)
set delivery tag of the message assigned by the transport
|
void |
setHeaders(Map<String,Object> headers)
set all headers for the message
|
void |
setMessageId(String messageId)
Set id for the message
|
void |
setReplyTo(String replyTo)
set 'ReplyTo' RabbitMQ header
|
void |
setSoapAction(String soapAction)
Set soap action to the message
|
public byte[] getBody()
public String getContentType()
public void setContentType(String contentType)
contentType
- content type to set for the messagepublic String getContentEncoding()
public void setContentEncoding(String contentEncoding)
contentEncoding
- return content encodingpublic String getCorrelationId()
public void setCorrelationId(String correlationId)
correlationId
- correlation id to setpublic String getReplyTo()
public void setReplyTo(String replyTo)
replyTo
- value of the header to setpublic String getMessageId()
public void setMessageId(String messageId)
messageId
- unique id for the messagepublic String getSoapAction()
public void setSoapAction(String soapAction)
soapAction
- soap action to e setpublic Map<String,Object> getHeaders()
public void setHeaders(Map<String,Object> headers)
headers
- a map of headers to be setpublic void setBody(byte[] body)
body
- bytes representing bodypublic void setDeliveryTag(long deliveryTag)
deliveryTag
- delivery tag to setpublic long getDeliveryTag()
Copyright © 2017 WSO2. All rights reserved.