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.AttributesImpl
getAttributes()
Optional<T>
getData()
Map<String,Object>
getExtensions()
T
getPayload()
String
toString()
-
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:
getAttributes
in interfaceio.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>
-
getData
public Optional<T> getData()
- Specified by:
getData
in interfaceio.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>
-
getExtensions
public Map<String,Object> getExtensions()
- Specified by:
getExtensions
in interfaceio.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>
-
getPayload
public T getPayload()
- Specified by:
getPayload
in interfaceMessage<T>
- Returns:
- The payload for this message.
-
-