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
-