Class ReactivePulsarTemplate.SendMessageBuilderImpl<T>
java.lang.Object
org.springframework.pulsar.reactive.core.ReactivePulsarTemplate.SendMessageBuilderImpl<T>
- All Implemented Interfaces:
ReactivePulsarOperations.SendMessageBuilder<T>
- Enclosing class:
- ReactivePulsarTemplate<T>
public static class ReactivePulsarTemplate.SendMessageBuilderImpl<T>
extends Object
implements ReactivePulsarOperations.SendMessageBuilder<T>
-
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<org.apache.pulsar.client.api.MessageId>send()Send the message in a reactive manner using the configured specification.withMessageCustomizer(MessageSpecBuilderCustomizer<T> messageCustomizer) Specifies the message customizer to use to further configure the message.withSenderCustomizer(ReactiveMessageSenderBuilderCustomizer<T> senderCustomizer) Specifies the customizer to use to further configure the reactive sender builder.Specify the topic to send the message to.
-
Method Details
-
withTopic
Description copied from interface:ReactivePulsarOperations.SendMessageBuilderSpecify the topic to send the message to.- Specified by:
withTopicin interfaceReactivePulsarOperations.SendMessageBuilder<T>- Parameters:
topic- the destination topic- Returns:
- the current builder with the destination topic specified
-
withMessageCustomizer
public ReactivePulsarTemplate.SendMessageBuilderImpl<T> withMessageCustomizer(MessageSpecBuilderCustomizer<T> messageCustomizer) Description copied from interface:ReactivePulsarOperations.SendMessageBuilderSpecifies the message customizer to use to further configure the message.- Specified by:
withMessageCustomizerin interfaceReactivePulsarOperations.SendMessageBuilder<T>- Parameters:
messageCustomizer- the message customizer- Returns:
- the current builder with the message customizer specified
-
withSenderCustomizer
public ReactivePulsarTemplate.SendMessageBuilderImpl<T> withSenderCustomizer(ReactiveMessageSenderBuilderCustomizer<T> senderCustomizer) Description copied from interface:ReactivePulsarOperations.SendMessageBuilderSpecifies the customizer to use to further configure the reactive sender builder.- Specified by:
withSenderCustomizerin interfaceReactivePulsarOperations.SendMessageBuilder<T>- Parameters:
senderCustomizer- the reactive sender builder customizer- Returns:
- the current builder with the reactive sender builder customizer specified
-
send
public reactor.core.publisher.Mono<org.apache.pulsar.client.api.MessageId> send()Description copied from interface:ReactivePulsarOperations.SendMessageBuilderSend the message in a reactive manner using the configured specification.- Specified by:
sendin interfaceReactivePulsarOperations.SendMessageBuilder<T>- Returns:
- the id assigned by the broker to the published message
-