Package | Description |
---|---|
io.smallrye.reactive.messaging.cloudevents | |
io.smallrye.reactive.messaging.example.eventclouds | |
io.smallrye.reactive.messaging.http.converters |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCloudEventMessage<T> |
Modifier and Type | Method and Description |
---|---|
CloudEventMessage<T> |
CloudEventMessageBuilder.build() |
CloudEventMessage<T> |
CloudEventMessageBuilder.build(T data,
io.cloudevents.v1.AttributesImpl attributes,
Collection<io.cloudevents.extensions.ExtensionFormat> extensions) |
Modifier and Type | Method and Description |
---|---|
CloudEventMessage<String> |
MyCloudEventProcessor.process(CloudEventMessage<String> message) |
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<CloudEventMessage<String>> |
MyCloudEventSource.source() |
Modifier and Type | Method and Description |
---|---|
CloudEventMessage<String> |
MyCloudEventProcessor.process(CloudEventMessage<String> message) |
Modifier and Type | Method and Description |
---|---|
Class<? extends CloudEventMessage> |
CloudEventSerializer.input() |
Modifier and Type | Method and Description |
---|---|
io.smallrye.mutiny.Uni<io.vertx.mutiny.core.buffer.Buffer> |
CloudEventSerializer.convert(CloudEventMessage payload) |
Copyright © 2018–2021 SmallRye. All rights reserved.