io.smallrye.reactive.messaging.amqp

Class OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

java.lang.Object

io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

Enclosing class:

OutgoingAmqpMetadata

public static final class OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
OutgoingAmqpMetadata	build()
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withAddress(String address)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withApplicationProperties(io.vertx.core.json.JsonObject json)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withApplicationProperty(String key, Object value)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withContentEncoding(String contentEncoding)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withContentType(String contentType)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withCorrelationId(String correlationId)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withCreationTime(long creationTime)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withDeliveryAnnotations(org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations deliveryAnnotations)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withDeliveryAnnotations(String key, Object value)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withDurable(boolean durable)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withExpiryTime(long expiryTime)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withFooter(String key, Object value)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withGroupId(String groupId)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withGroupSequence(int groupSequence)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withMessageAnnotations(org.apache.qpid.proton.amqp.messaging.MessageAnnotations messageAnnotations)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withMessageAnnotations(String key, Object value)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withMessageId(String id)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withPriority(short priority)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withReplyTo(String replyTo)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withReplyToGroupId(String replyToGroupId)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withSubject(String subject)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withTtl(long ttl)
OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	withUserId(String userId)

Methods inherited from class java.lang.Object

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

Method Detail

withAddress

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withAddress(String address)

withDurable

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withDurable(boolean durable)

withPriority

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withPriority(short priority)

withTtl

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withTtl(long ttl)

withDeliveryAnnotations

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withDeliveryAnnotations(org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations deliveryAnnotations)

withMessageAnnotations

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withMessageAnnotations(org.apache.qpid.proton.amqp.messaging.MessageAnnotations messageAnnotations)

withDeliveryAnnotations

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withDeliveryAnnotations(String key,
                                                                                Object value)

withMessageAnnotations

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withMessageAnnotations(String key,
                                                                               Object value)

withMessageId

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withMessageId(String id)

withUserId

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withUserId(String userId)

withReplyTo

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withReplyTo(String replyTo)

withCorrelationId

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withCorrelationId(String correlationId)

withContentType

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withContentType(String contentType)

withContentEncoding

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withContentEncoding(String contentEncoding)

withExpiryTime

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withExpiryTime(long expiryTime)

withCreationTime

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withCreationTime(long creationTime)

withGroupId

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withGroupId(String groupId)

withGroupSequence

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withGroupSequence(int groupSequence)

withReplyToGroupId

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withReplyToGroupId(String replyToGroupId)

withSubject

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withSubject(String subject)

withApplicationProperty

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withApplicationProperty(String key,
                                                                                Object value)

withApplicationProperties

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withApplicationProperties(io.vertx.core.json.JsonObject json)

withFooter

public OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder withFooter(String key,
                                                                   Object value)

build

public OutgoingAmqpMetadata build()