io.smallrye.reactive.messaging.cloudevents

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 and Description
DefaultCloudEventMessage(io.cloudevents.v1.CloudEventImpl<T> delegate)

Method Summary

Modifier and Type	Method and 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, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, 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 interface io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>

getData

public Optional<T> getData()

Specified by:

getData in interface io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>

getExtensions

public Map<String,Object> getExtensions()

Specified by:

getExtensions in interface io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,T>

getPayload

public T getPayload()

Specified by:

getPayload in interface Message<T>

Returns:

The payload for this message.

toString

public String toString()

Overrides:

toString in class Object