Class CamelMessage<T>
- java.lang.Object
-
- io.smallrye.reactive.messaging.camel.CamelMessage<T>
-
-
Constructor Summary
Constructors Constructor Description CamelMessage(org.apache.camel.Exchange exchange, CamelFailureHandler onNack)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.ExchangegetExchange()MetadatagetMetadata()TgetPayload()TgetPayload(Class<T> clazz)CompletionStage<Void>nack(Throwable reason)Acknowledge negatively this message.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message
ack, addMetadata, getAck, getMetadata, getNack, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload
-
-
-
-
Constructor Detail
-
CamelMessage
public CamelMessage(org.apache.camel.Exchange exchange, CamelFailureHandler onNack)
-
-
Method Detail
-
getPayload
public T getPayload()
- Specified by:
getPayloadin interfaceMessage<T>- Returns:
- The payload for this message.
-
getExchange
public org.apache.camel.Exchange getExchange()
-
getMetadata
public Metadata getMetadata()
- Specified by:
getMetadatain interfaceMessage<T>- Returns:
- The set of metadata attached to this message, potentially empty.
-
nack
public CompletionStage<Void> nack(Throwable reason)
Description copied from interface:MessageAcknowledge negatively this message.nackis used to indicate that the processing of a message failed. The reason is passed as parameter.
-
-