Package io.smallrye.reactive.messaging.amqp

Class OutgoingAmqpMetadata

java.lang.Object

io.smallrye.reactive.messaging.amqp.OutgoingAmqpMetadata

public class OutgoingAmqpMetadata
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder

Constructor Summary

Constructors

Constructor	Description
OutgoingAmqpMetadata()
OutgoingAmqpMetadata(String address, boolean durable, short priority, long ttl, org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations deliveryAnnotations, org.apache.qpid.proton.amqp.messaging.MessageAnnotations messageAnnotations, String id, String userId, String subject, String replyTo, String correlationId, String contentType, String contentEncoding, long expiryTime, long creationTime, String groupId, long groupSequence, String replyToGroupId, io.vertx.core.json.JsonObject applicationProperties, org.apache.qpid.proton.amqp.messaging.Footer footer)

Method Summary

Modifier and Type	Method	Description
static OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	builder()
static OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder	from(OutgoingAmqpMetadata existing)
String	getAddress()
String	getContentEncoding()
String	getContentType()
String	getCorrelationId()
long	getCreationTime()
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations	getDeliveryAnnotations()
long	getExpiryTime()
org.apache.qpid.proton.amqp.messaging.Footer	getFooter()
String	getGroupId()
long	getGroupSequence()
org.apache.qpid.proton.amqp.messaging.MessageAnnotations	getMessageAnnotations()
String	getMessageId()
short	getPriority()
io.vertx.core.json.JsonObject	getProperties()
String	getReplyTo()
String	getReplyToGroupId()
String	getSubject()
long	getTtl()
String	getUserId()
boolean	isDurable()

Methods inherited from class java.lang.Object

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

Constructor Detail

OutgoingAmqpMetadata

public OutgoingAmqpMetadata()

OutgoingAmqpMetadata

public OutgoingAmqpMetadata(String address,
                            boolean durable,
                            short priority,
                            long ttl,
                            org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations deliveryAnnotations,
                            org.apache.qpid.proton.amqp.messaging.MessageAnnotations messageAnnotations,
                            String id,
                            String userId,
                            String subject,
                            String replyTo,
                            String correlationId,
                            String contentType,
                            String contentEncoding,
                            long expiryTime,
                            long creationTime,
                            String groupId,
                            long groupSequence,
                            String replyToGroupId,
                            io.vertx.core.json.JsonObject applicationProperties,
                            org.apache.qpid.proton.amqp.messaging.Footer footer)

Method Detail

getAddress

public String getAddress()

getUserId

public String getUserId()

getReplyTo

public String getReplyTo()

getGroupId

public String getGroupId()

getContentType

public String getContentType()

getExpiryTime

public long getExpiryTime()

getCorrelationId

public String getCorrelationId()

getContentEncoding

public String getContentEncoding()

getSubject

public String getSubject()

getDeliveryAnnotations

public org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations getDeliveryAnnotations()

getMessageAnnotations

public org.apache.qpid.proton.amqp.messaging.MessageAnnotations getMessageAnnotations()

getFooter

public org.apache.qpid.proton.amqp.messaging.Footer getFooter()

isDurable

public boolean isDurable()

getPriority

public short getPriority()

getTtl

public long getTtl()

getMessageId

public String getMessageId()

getGroupSequence

public long getGroupSequence()

getReplyToGroupId

public String getReplyToGroupId()

getCreationTime

public long getCreationTime()

getProperties

public io.vertx.core.json.JsonObject getProperties()

builder

public static OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder builder()

from

public static OutgoingAmqpMetadata.OutgoingAmqpMetadataBuilder from(OutgoingAmqpMetadata existing)