AmqpMessageBuilder

Builder to create a new {@link AmqpMessage}. <p> Reference about the different metadata can be found on <a href="http://docs.oasis-open.org/amqp/core/v1.0/amqp-core-messaging-v1.0.html#type-properties">AMQP message properties</a>. <p> Note that the body is set using {@code withBodyAs*} method depending on the passed type.

Members

Functions

address
AmqpMessageBuilder address(string address)
Undocumented in source.
build
AmqpMessage build()

@return the message.

contentEncoding
AmqpMessageBuilder contentEncoding(string ct)
Undocumented in source.
contentType
AmqpMessageBuilder contentType(string ct)
Undocumented in source.
correlationId
AmqpMessageBuilder correlationId(string correlationId)
Undocumented in source.
creationTime
AmqpMessageBuilder creationTime(long ct)
Undocumented in source.
deliveryCount
AmqpMessageBuilder deliveryCount(int count)
Undocumented in source.
durable
AmqpMessageBuilder durable(bool durable)
Undocumented in source.
expiryTime
AmqpMessageBuilder expiryTime(long expiry)
Undocumented in source.
firstAcquirer
AmqpMessageBuilder firstAcquirer(bool first)
Undocumented in source.
groupId
AmqpMessageBuilder groupId(string gi)
Undocumented in source.
id
AmqpMessageBuilder id(string id)
Undocumented in source.
priority
AmqpMessageBuilder priority(short priority)
Undocumented in source.
replyTo
AmqpMessageBuilder replyTo(string replyTo)
Undocumented in source.
replyToGroupId
AmqpMessageBuilder replyToGroupId(string rt)
Undocumented in source.
subject
AmqpMessageBuilder subject(string subject)
Undocumented in source.
ttl
AmqpMessageBuilder ttl(long ttl)
Undocumented in source.
withBody
AmqpMessageBuilder withBody(string value)
Undocumented in source.
withBooleanAsBody
AmqpMessageBuilder withBooleanAsBody(bool v)
Undocumented in source.
withByteAsBody
AmqpMessageBuilder withByteAsBody(byte v)
Undocumented in source.
withCharAsBody
AmqpMessageBuilder withCharAsBody(char c)
Undocumented in source.
withDoubleAsBody
AmqpMessageBuilder withDoubleAsBody(double v)
Undocumented in source.
withFloatAsBody
AmqpMessageBuilder withFloatAsBody(float v)
Undocumented in source.
withIntegerAsBody
AmqpMessageBuilder withIntegerAsBody(int v)
Undocumented in source.
withLongAsBody
AmqpMessageBuilder withLongAsBody(long v)
Undocumented in source.
withShortAsBody
AmqpMessageBuilder withShortAsBody(short v)
Undocumented in source.
withSymbolAsBody
AmqpMessageBuilder withSymbolAsBody(string value)
Undocumented in source.

Static functions

create
AmqpMessageBuilder create()

@return a new instance of {@link AmqpMessageBuilder}

Meta