Interface ReactivePulsarOperations.SendMessageBuilder<O,T>
- Type Parameters:
O- the builder typeT- the message payload type
- All Known Subinterfaces:
ReactivePulsarOperations.SendManyMessageBuilder<T>,ReactivePulsarOperations.SendOneMessageBuilder<T>
- Enclosing interface:
- ReactivePulsarOperations<T>
public static sealed interface ReactivePulsarOperations.SendMessageBuilder<O,T>
permits ReactivePulsarOperations.SendOneMessageBuilder<T>, ReactivePulsarOperations.SendManyMessageBuilder<T>
Builder that can be used to configure and send a message. Provides more options
than the send methods provided by
ReactivePulsarOperations.-
Method Summary
Modifier and TypeMethodDescriptionwithSchema(org.apache.pulsar.client.api.Schema<T> schema) Specify the schema to use when sending the message.withSenderCustomizer(ReactiveMessageSenderBuilderCustomizer<T> customizer) Specifies the customizer to use to further configure the reactive sender builder.Specify the topic to send the message to.
-
Method Details
-
withTopic
Specify the topic to send the message to.- Parameters:
topic- the destination topic- Returns:
- the current builder with the destination topic specified
-
withSchema
Specify the schema to use when sending the message.- Parameters:
schema- the schema to use- Returns:
- the current builder with the schema specified
-
withSenderCustomizer
Specifies the customizer to use to further configure the reactive sender builder.- Parameters:
customizer- the reactive sender builder customizer- Returns:
- the current builder with the reactive sender builder customizer specified
-