Package org.apache.beam.sdk.io.rabbitmq

Class RabbitMqMessage

java.lang.Object

org.apache.beam.sdk.io.rabbitmq.RabbitMqMessage

All Implemented Interfaces:

Serializable

public class RabbitMqMessage
extends Object
implements Serializable

It contains the message payload, and additional metadata like routing key or attributes. The main reason of this class is that AMQP.BasicProperties doesn't provide a serializable public API.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RabbitMqMessage(byte[] body)
RabbitMqMessage(String routingKey, byte[] body, String contentType, String contentEncoding, Map<String,Object> headers, Integer deliveryMode, Integer priority, String correlationId, String replyTo, String expiration, String messageId, Date timestamp, String type, String userId, String appId, String clusterId)
RabbitMqMessage(String routingKey, com.rabbitmq.client.GetResponse delivery)

Method Summary

Modifier and Type	Method	Description
com.rabbitmq.client.AMQP.BasicProperties	createProperties()
boolean	equals(@Nullable Object obj)
String	getAppId()
byte[]	getBody()
String	getClusterId()
String	getContentEncoding()
String	getContentType()
String	getCorrelationId()
Integer	getDeliveryMode()
String	getExpiration()
Map<String,Object>	getHeaders()
String	getMessageId()
Integer	getPriority()
String	getReplyTo()
String	getRoutingKey()
Date	getTimestamp()
String	getType()
String	getUserId()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMqMessage

public RabbitMqMessage(byte[] body)

RabbitMqMessage

public RabbitMqMessage(String routingKey,
 com.rabbitmq.client.GetResponse delivery)

RabbitMqMessage

public RabbitMqMessage(String routingKey,
 byte[] body,
 String contentType,
 String contentEncoding,
 Map<String,Object> headers,
 Integer deliveryMode,
 Integer priority,
 String correlationId,
 String replyTo,
 String expiration,
 String messageId,
 Date timestamp,
 String type,
 String userId,
 String appId,
 String clusterId)

Method Details

getRoutingKey

public String getRoutingKey()

getBody

public byte[] getBody()

getContentType

public String getContentType()

getContentEncoding

public String getContentEncoding()

getHeaders

public Map<String,Object> getHeaders()

getDeliveryMode

public Integer getDeliveryMode()

getPriority

public Integer getPriority()

getCorrelationId

public String getCorrelationId()

getReplyTo

public String getReplyTo()

getExpiration

public String getExpiration()

getMessageId

public String getMessageId()

getTimestamp

public Date getTimestamp()

getType

public String getType()

getUserId

public String getUserId()

getAppId

public String getAppId()

getClusterId

public String getClusterId()

createProperties

public com.rabbitmq.client.AMQP.BasicProperties createProperties()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(@Nullable Object obj)

Overrides:

equals in class Object