Class DefaultCloudEventMessage<T>
- java.lang.Object
-
- io.smallrye.reactive.messaging.cloudevents.DefaultCloudEventMessage<T>
-
- All Implemented Interfaces:
io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>,CloudEventMessage<T>,Message<T>
public class DefaultCloudEventMessage<T> extends Object implements CloudEventMessage<T>
-
-
Constructor Summary
Constructors Constructor Description DefaultCloudEventMessage(io.cloudevents.v1.CloudEventImpl<T> delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.cloudevents.v1.AttributesImplgetAttributes()Optional<T>getData()Map<String,Object>getExtensions()TgetPayload()StringtoString()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message
ack, addMetadata, getAck, getMetadata, getMetadata, getNack, nack, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload
-
-
-
-
Constructor Detail
-
DefaultCloudEventMessage
public DefaultCloudEventMessage(io.cloudevents.v1.CloudEventImpl<T> delegate)
-
-
Method Detail
-
getAttributes
public io.cloudevents.v1.AttributesImpl getAttributes()
- Specified by:
getAttributesin interfaceio.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>
-
getData
public Optional<T> getData()
- Specified by:
getDatain interfaceio.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>
-
getExtensions
public Map<String,Object> getExtensions()
- Specified by:
getExtensionsin interfaceio.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>
-
getPayload
public T getPayload()
- Specified by:
getPayloadin interfaceMessage<T>- Returns:
- The payload for this message.
-
-