org.apache.beam.sdk.io.rabbitmq

Class RabbitMqMessage

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public class RabbitMqMessage
extends java.lang.Object
implements java.io.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 and Description
RabbitMqMessage(byte[] body)
RabbitMqMessage(java.lang.String routingKey, byte[] body, java.lang.String contentType, java.lang.String contentEncoding, java.util.Map<java.lang.String,java.lang.Object> headers, java.lang.Integer deliveryMode, java.lang.Integer priority, java.lang.String correlationId, java.lang.String replyTo, java.lang.String expiration, java.lang.String messageId, java.util.Date timestamp, java.lang.String type, java.lang.String userId, java.lang.String appId, java.lang.String clusterId)
RabbitMqMessage(java.lang.String routingKey, com.rabbitmq.client.GetResponse delivery)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMqMessage

public RabbitMqMessage(byte[] body)

RabbitMqMessage

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

RabbitMqMessage

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

Method Detail

getRoutingKey

public java.lang.String getRoutingKey()

getBody

public byte[] getBody()

getContentType

public java.lang.String getContentType()

getContentEncoding

public java.lang.String getContentEncoding()

getHeaders

public java.util.Map<java.lang.String,java.lang.Object> getHeaders()

getDeliveryMode

public java.lang.Integer getDeliveryMode()

getPriority

public java.lang.Integer getPriority()

getCorrelationId

public java.lang.String getCorrelationId()

getReplyTo

public java.lang.String getReplyTo()

getExpiration

public java.lang.String getExpiration()

getMessageId

public java.lang.String getMessageId()

getTimestamp

public java.util.Date getTimestamp()

getType

public java.lang.String getType()

getUserId

public java.lang.String getUserId()

getAppId

public java.lang.String getAppId()

getClusterId

public java.lang.String getClusterId()

createProperties

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

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(@Nullable java.lang.Object obj)

Overrides:

equals in class java.lang.Object