Main API for RabbitMQ Stream Java Client.
Implementations of AMQP 1.0
Codec
.
-
Set the content encoding.
MessageBuilder.PropertiesBuilder.correlationId(byte[] correlationId)
Set the correlation ID as an array of bytes.
MessageBuilder.PropertiesBuilder.correlationId(long correlationId)
Set the correlation ID as a long.
Set the correlation ID as a string.
Set the correlation ID as an UUID.
MessageBuilder.PropertiesBuilder.creationTime(long creationTime)
MessageBuilder.PropertiesBuilder.groupSequence(long groupSequence)
MessageBuilder.PropertiesBuilder.messageId(byte[] id)
Set the message ID as an array of bytes.
MessageBuilder.PropertiesBuilder.messageId(long id)
Set the message ID as long.
Set the message ID as a string.
Set the message ID as an UUID.
Set the reply to address.
Set the reply-to group ID.
MessageBuilder.PropertiesBuilder.to(String address)
MessageBuilder.PropertiesBuilder.userId(byte[] userId)
-