Package io.smallrye.reactive.messaging.amqp

Class AmqpMessageBuilder<T>

java.lang.Object

io.smallrye.reactive.messaging.amqp.AmqpMessageBuilder<T>

public class AmqpMessageBuilder<T>
extends Object

Method Summary

Modifier and Type	Method	Description
AmqpMessage<T>	build()
AmqpMessageBuilder<T>	withAddress(String address)
AmqpMessageBuilder<T>	withApplicationProperties(io.vertx.core.json.JsonObject props)
AmqpMessageBuilder<T>	withBody(String value)
AmqpMessageBuilder<T>	withBooleanAsBody(boolean v)
AmqpMessageBuilder<T>	withBufferAsBody(io.vertx.mutiny.core.buffer.Buffer buffer)
AmqpMessageBuilder<T>	withByteAsBody(byte v)
AmqpMessageBuilder<T>	withCharAsBody(char c)
AmqpMessageBuilder<T>	withContentEncoding(String ct)
AmqpMessageBuilder<T>	withContentType(String ct)
AmqpMessageBuilder<T>	withCorrelationId(String correlationId)
AmqpMessageBuilder<T>	withDoubleAsBody(double v)
AmqpMessageBuilder<T>	withDurable(boolean durable)
AmqpMessageBuilder<T>	withFloatAsBody(float v)
AmqpMessageBuilder<T>	withGroupId(String gi)
AmqpMessageBuilder<T>	withId(String id)
AmqpMessageBuilder<T>	withInstantAsBody(Instant v)
AmqpMessageBuilder<T>	withIntegerAsBody(int v)
AmqpMessageBuilder<T>	withJsonArrayAsBody(io.vertx.core.json.JsonArray json)
AmqpMessageBuilder<T>	withJsonObjectAsBody(io.vertx.core.json.JsonObject json)
AmqpMessageBuilder<T>	withLongAsBody(long v)
AmqpMessageBuilder<T>	withPriority(short priority)
AmqpMessageBuilder<T>	withReplyTo(String replyTo)
AmqpMessageBuilder<T>	withReplyToGroupId(String rt)
AmqpMessageBuilder<T>	withShortAsBody(short v)
AmqpMessageBuilder<T>	withSubject(String subject)
AmqpMessageBuilder<T>	withSymbolAsBody(String value)
AmqpMessageBuilder<T>	withTtl(long ttl)
AmqpMessageBuilder<T>	withUuidAsBody(UUID v)

Methods inherited from class java.lang.Object

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

Method Detail

withPriority

public AmqpMessageBuilder<T> withPriority(short priority)

withDurable

public AmqpMessageBuilder<T> withDurable(boolean durable)

withTtl

public AmqpMessageBuilder<T> withTtl(long ttl)

withId

public AmqpMessageBuilder<T> withId(String id)

withAddress

public AmqpMessageBuilder<T> withAddress(String address)

withReplyTo

public AmqpMessageBuilder<T> withReplyTo(String replyTo)

withCorrelationId

public AmqpMessageBuilder<T> withCorrelationId(String correlationId)

withBody

public AmqpMessageBuilder<T> withBody(String value)

withSymbolAsBody

public AmqpMessageBuilder<T> withSymbolAsBody(String value)

withSubject

public AmqpMessageBuilder<T> withSubject(String subject)

withContentType

public AmqpMessageBuilder<T> withContentType(String ct)

withContentEncoding

public AmqpMessageBuilder<T> withContentEncoding(String ct)

withGroupId

public AmqpMessageBuilder<T> withGroupId(String gi)

withReplyToGroupId

public AmqpMessageBuilder<T> withReplyToGroupId(String rt)

withApplicationProperties

public AmqpMessageBuilder<T> withApplicationProperties(io.vertx.core.json.JsonObject props)

withBooleanAsBody

public AmqpMessageBuilder<T> withBooleanAsBody(boolean v)

withByteAsBody

public AmqpMessageBuilder<T> withByteAsBody(byte v)

withShortAsBody

public AmqpMessageBuilder<T> withShortAsBody(short v)

withIntegerAsBody

public AmqpMessageBuilder<T> withIntegerAsBody(int v)

withLongAsBody

public AmqpMessageBuilder<T> withLongAsBody(long v)

withFloatAsBody

public AmqpMessageBuilder<T> withFloatAsBody(float v)

withDoubleAsBody

public AmqpMessageBuilder<T> withDoubleAsBody(double v)

withCharAsBody

public AmqpMessageBuilder<T> withCharAsBody(char c)

withBufferAsBody

public AmqpMessageBuilder<T> withBufferAsBody(io.vertx.mutiny.core.buffer.Buffer buffer)

withJsonObjectAsBody

public AmqpMessageBuilder<T> withJsonObjectAsBody(io.vertx.core.json.JsonObject json)

withJsonArrayAsBody

public AmqpMessageBuilder<T> withJsonArrayAsBody(io.vertx.core.json.JsonArray json)

withInstantAsBody

public AmqpMessageBuilder<T> withInstantAsBody(Instant v)

withUuidAsBody

public AmqpMessageBuilder<T> withUuidAsBody(UUID v)

build

public AmqpMessage<T> build()