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 classDefaultIncomingCloudEventMetadata<T>Default implementation of theIncomingCloudEventMetadatainterface -
Uses of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.kafka
Subinterfaces of IncomingCloudEventMetadata in io.smallrye.reactive.messaging.kafka Modifier and Type Interface Description interfaceIncomingKafkaCloudEventMetadata<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 classDefaultIncomingKafkaCloudEventMetadata<K,T>Constructors in io.smallrye.reactive.messaging.kafka.impl.ce with parameters of type IncomingCloudEventMetadata Constructor Description DefaultIncomingKafkaCloudEventMetadata(IncomingCloudEventMetadata<T> delegate)
-