public class AmqpMessageBuilder extends Object
AmqpMessage
.
Reference about the different metadata can be found on AMQP message properties.
Note that the body is set using withBodyAs*
method depending on the passed type.
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<AmqpMessageBuilder> |
__TYPE_ARG |
Constructor and Description |
---|
AmqpMessageBuilder(AmqpMessageBuilder delegate) |
AmqpMessageBuilder(Object delegate) |
public static final io.vertx.lang.rx.TypeArg<AmqpMessageBuilder> __TYPE_ARG
public AmqpMessageBuilder(AmqpMessageBuilder delegate)
public AmqpMessageBuilder(Object delegate)
public AmqpMessageBuilder getDelegate()
public static AmqpMessageBuilder create()
AmqpMessageBuilder
public AmqpMessage build()
public AmqpMessageBuilder priority(short priority)
public AmqpMessageBuilder durable(boolean durable)
public AmqpMessageBuilder ttl(long ttl)
public AmqpMessageBuilder firstAcquirer(boolean first)
public AmqpMessageBuilder deliveryCount(int count)
public AmqpMessageBuilder id(String id)
public AmqpMessageBuilder address(String address)
public AmqpMessageBuilder replyTo(String replyTo)
public AmqpMessageBuilder correlationId(String correlationId)
public AmqpMessageBuilder withBody(String value)
public AmqpMessageBuilder withSymbolAsBody(String value)
public AmqpMessageBuilder subject(String subject)
public AmqpMessageBuilder contentType(String ct)
public AmqpMessageBuilder contentEncoding(String ct)
public AmqpMessageBuilder expiryTime(long expiry)
public AmqpMessageBuilder creationTime(long ct)
public AmqpMessageBuilder groupId(String gi)
public AmqpMessageBuilder replyToGroupId(String rt)
public AmqpMessageBuilder applicationProperties(JsonObject props)
public AmqpMessageBuilder withBooleanAsBody(boolean v)
public AmqpMessageBuilder withByteAsBody(byte v)
public AmqpMessageBuilder withShortAsBody(short v)
public AmqpMessageBuilder withIntegerAsBody(int v)
public AmqpMessageBuilder withLongAsBody(long v)
public AmqpMessageBuilder withFloatAsBody(float v)
public AmqpMessageBuilder withDoubleAsBody(double v)
public AmqpMessageBuilder withCharAsBody(char c)
public AmqpMessageBuilder withBufferAsBody(Buffer buffer)
public AmqpMessageBuilder withJsonObjectAsBody(JsonObject json)
public AmqpMessageBuilder withJsonArrayAsBody(JsonArray json)
public AmqpMessageBuilder withInstantAsBody(java.time.Instant v)
public AmqpMessageBuilder withUuidAsBody(UUID v)
public static AmqpMessageBuilder newInstance(AmqpMessageBuilder arg)
Copyright © 2022 Eclipse. All rights reserved.