Uses of Interface
io.smallrye.reactive.messaging.ce.OutgoingCloudEventMetadata
-
Packages that use OutgoingCloudEventMetadata Package Description io.smallrye.reactive.messaging.ce io.smallrye.reactive.messaging.ce.impl io.smallrye.reactive.messaging.kafka.impl.ce -
-
Uses of OutgoingCloudEventMetadata in io.smallrye.reactive.messaging.ce
Methods in io.smallrye.reactive.messaging.ce that return OutgoingCloudEventMetadata Modifier and Type Method Description OutgoingCloudEventMetadata<T>OutgoingCloudEventMetadataBuilder. build()Methods in io.smallrye.reactive.messaging.ce with parameters of type OutgoingCloudEventMetadata Modifier and Type Method Description static <T> OutgoingCloudEventMetadataBuilder<T>OutgoingCloudEventMetadata. from(OutgoingCloudEventMetadata<T> existing)Gets a builder to create a newOutgoingCloudEventMetadata.Constructors in io.smallrye.reactive.messaging.ce with parameters of type OutgoingCloudEventMetadata Constructor Description OutgoingCloudEventMetadataBuilder(OutgoingCloudEventMetadata<T> existing) -
Uses of OutgoingCloudEventMetadata in io.smallrye.reactive.messaging.ce.impl
Classes in io.smallrye.reactive.messaging.ce.impl that implement OutgoingCloudEventMetadata Modifier and Type Class Description classDefaultOutgoingCloudEventMetadata<T>Default implementation of theOutgoingCloudEventMetadatainterface. -
Uses of OutgoingCloudEventMetadata in io.smallrye.reactive.messaging.kafka.impl.ce
Methods in io.smallrye.reactive.messaging.kafka.impl.ce with parameters of type OutgoingCloudEventMetadata Modifier and Type Method Description static org.apache.kafka.clients.producer.ProducerRecord<?,?>KafkaCloudEventHelper. createBinaryRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)static org.apache.kafka.clients.producer.ProducerRecord<?,?>KafkaCloudEventHelper. createStructuredRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)
-