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 and Description
OutgoingCloudEventMetadata<T>	OutgoingCloudEventMetadataBuilder.build()

Methods in io.smallrye.reactive.messaging.ce with parameters of type OutgoingCloudEventMetadata

Modifier and Type	Method and Description
static <T> OutgoingCloudEventMetadataBuilder<T>	OutgoingCloudEventMetadata.from(OutgoingCloudEventMetadata<T> existing) Gets a builder to create a new OutgoingCloudEventMetadata.

Constructors in io.smallrye.reactive.messaging.ce with parameters of type OutgoingCloudEventMetadata

Constructor and 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 and Description
class	DefaultOutgoingCloudEventMetadata<T> Default implementation of the OutgoingCloudEventMetadata interface.

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 and 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)