Uses of Interface
io.smallrye.reactive.messaging.ce.IncomingCloudEventMetadata
-
-
Uses of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.amqp.ce
Methods in io.smallrye.reactive.messaging.amqp.ce that return IncomingCloudEventMetadata Modifier and Type Method Description static <T> IncomingCloudEventMetadata<T>
AmqpCloudEventHelper. createFromBinaryCloudEvent(io.vertx.amqp.AmqpMessage message, AmqpMessage<T> parent)
static <T> IncomingCloudEventMetadata<T>
AmqpCloudEventHelper. createFromStructuredCloudEvent(io.vertx.amqp.AmqpMessage message)
-
Uses of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.ce.impl
Classes in io.smallrye.reactive.messaging.ce.impl that implement IncomingCloudEventMetadata Modifier and Type Class Description class
DefaultIncomingCloudEventMetadata<T>
Default implementation of theIncomingCloudEventMetadata
interface -
Uses of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.kafka
Subinterfaces of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.kafka Modifier and Type Interface Description interface
IncomingKafkaCloudEventMetadata<K,T>
Addition "extension" attribute specific to incoming Kafka record -
Uses of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.kafka.impl.ce
Classes in io.smallrye.reactive.messaging.kafka.impl.ce that implement IncomingCloudEventMetadata Modifier and Type Class Description class
DefaultIncomingKafkaCloudEventMetadata<K,T>
Constructors in io.smallrye.reactive.messaging.kafka.impl.ce with parameters of type IncomingCloudEventMetadata Constructor Description DefaultIncomingKafkaCloudEventMetadata(IncomingCloudEventMetadata<T> delegate)
-