public class AmqpMessage<T> extends Object implements Message<T>
Modifier and Type | Field and Description |
---|---|
protected IncomingAmqpMetadata |
amqpMetadata |
protected static String |
APPLICATION_JSON |
protected io.vertx.amqp.AmqpMessage |
message |
protected Metadata |
metadata |
protected AmqpFailureHandler |
onNack |
Constructor and Description |
---|
AmqpMessage(io.vertx.mutiny.amqp.AmqpMessage delegate,
io.vertx.mutiny.core.Context context,
AmqpFailureHandler onNack) |
AmqpMessage(io.vertx.amqp.AmqpMessage msg,
io.vertx.mutiny.core.Context context,
AmqpFailureHandler onNack) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMetadata, getMetadata, of, of, of, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload
protected static final String APPLICATION_JSON
protected final io.vertx.amqp.AmqpMessage message
protected final Metadata metadata
protected final IncomingAmqpMetadata amqpMetadata
protected final AmqpFailureHandler onNack
public AmqpMessage(io.vertx.mutiny.amqp.AmqpMessage delegate, io.vertx.mutiny.core.Context context, AmqpFailureHandler onNack)
public AmqpMessage(io.vertx.amqp.AmqpMessage msg, io.vertx.mutiny.core.Context context, AmqpFailureHandler onNack)
@Deprecated public static <T> AmqpMessageBuilder<T> builder()
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.public T getPayload()
getPayload
in interface Message<T>
public Metadata getMetadata()
getMetadata
in interface Message<T>
public org.apache.qpid.proton.message.Message unwrap()
public boolean isDurable()
public long getDeliveryCount()
public int getPriority()
public long getTtl()
public Object getMessageId()
public long getGroupSequence()
public long getCreationTime()
public String getAddress()
public String getGroupId()
public String getContentType()
public long getExpiryTime()
public Object getCorrelationId()
public String getContentEncoding()
public String getSubject()
public io.vertx.core.json.JsonObject getApplicationProperties()
public org.apache.qpid.proton.amqp.messaging.Section getBody()
public org.apache.qpid.proton.message.MessageError getError()
public io.vertx.mutiny.amqp.AmqpMessage getAmqpMessage()
public Supplier<CompletionStage<Void>> getAck()
getAck
in interface Message<T>
CompletionStage
.Copyright © 2018–2021 SmallRye. All rights reserved.