Uses of Interface
io.smallrye.reactive.messaging.ce.OutgoingCloudEventMetadata
-
-
Uses of OutgoingCloudEventMetadata in io.smallrye.reactive.messaging.amqp.ce
Methods in io.smallrye.reactive.messaging.amqp.ce with parameters of type OutgoingCloudEventMetadata Modifier and Type Method Description static io.vertx.mutiny.amqp.AmqpMessage
AmqpCloudEventHelper. createBinaryCloudEventMessage(io.vertx.mutiny.amqp.AmqpMessage message, OutgoingCloudEventMetadata<?> ceMetadata, AmqpConnectorOutgoingConfiguration configuration)
static io.vertx.mutiny.amqp.AmqpMessage
AmqpCloudEventHelper. createStructuredEventMessage(io.vertx.mutiny.amqp.AmqpMessage message, OutgoingCloudEventMetadata<?> ceMetadata, AmqpConnectorOutgoingConfiguration configuration)
-
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 class
DefaultOutgoingCloudEventMetadata<T>
Default implementation of theOutgoingCloudEventMetadata
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 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)
-