public class OutgoingAmqpMessage<T> extends AmqpMessage<T> implements Message<T>
APPLICATION_JSON, message, onNack
Constructor and Description |
---|
OutgoingAmqpMessage(io.vertx.mutiny.amqp.AmqpMessage message,
OutgoingAmqpMetadata amqpMetadata) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
ack()
Acknowledge this message.
|
Supplier<CompletionStage<Void>> |
getAck() |
String |
getAddress() |
io.vertx.core.json.JsonObject |
getApplicationProperties() |
String |
getContentEncoding() |
String |
getContentType() |
Object |
getCorrelationId() |
String |
getGroupId() |
Object |
getMessageId() |
Metadata |
getMetadata() |
Function<Throwable,CompletionStage<Void>> |
getNack() |
int |
getPriority() |
String |
getSubject() |
long |
getTtl() |
boolean |
isDurable() |
CompletionStage<Void> |
nack(Throwable reason)
Acknowledge negatively this message.
|
builder, getAmqpMessage, getBody, getCreationTime, getDeliveryCount, getError, getExpiryTime, getGroupSequence, getPayload, unwrap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMetadata, getMetadata, getPayload, of, of, of, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload
public OutgoingAmqpMessage(io.vertx.mutiny.amqp.AmqpMessage message, OutgoingAmqpMetadata amqpMetadata)
public Metadata getMetadata()
getMetadata
in interface Message<T>
getMetadata
in class AmqpMessage<T>
public boolean isDurable()
isDurable
in class AmqpMessage<T>
public int getPriority()
getPriority
in class AmqpMessage<T>
public long getTtl()
getTtl
in class AmqpMessage<T>
public Object getMessageId()
getMessageId
in class AmqpMessage<T>
public String getAddress()
getAddress
in class AmqpMessage<T>
public String getGroupId()
getGroupId
in class AmqpMessage<T>
public String getContentType()
getContentType
in class AmqpMessage<T>
public Object getCorrelationId()
getCorrelationId
in class AmqpMessage<T>
public String getContentEncoding()
getContentEncoding
in class AmqpMessage<T>
public String getSubject()
getSubject
in class AmqpMessage<T>
public CompletionStage<Void> ack()
Message
public CompletionStage<Void> nack(Throwable reason)
Message
nack
is used to indicate that the processing of a message failed. The reason is passed as parameter.nack
in interface Message<T>
nack
in class AmqpMessage<T>
reason
- the reason of the nack, must not be null
public Supplier<CompletionStage<Void>> getAck()
getAck
in interface Message<T>
getAck
in class AmqpMessage<T>
CompletionStage
.public Function<Throwable,CompletionStage<Void>> getNack()
public io.vertx.core.json.JsonObject getApplicationProperties()
getApplicationProperties
in class AmqpMessage<T>
Copyright © 2018–2021 SmallRye. All rights reserved.