Uses of Interface
org.apache.pulsar.client.api.Producer
Packages that use Producer
Package
Description
Pulsar Client API.
Pulsar interceptors.
-
Uses of Producer in org.apache.pulsar.client.api
Methods in org.apache.pulsar.client.api that return ProducerModifier and TypeMethodDescriptionProducerBuilder.create()
Finalize the creation of theProducer
instance.Methods in org.apache.pulsar.client.api that return types with arguments of type ProducerModifier and TypeMethodDescriptionProducerBuilder.createAsync()
Finalize the creation of theProducer
instance in asynchronous mode.Methods in org.apache.pulsar.client.api with parameters of type ProducerModifier and TypeMethodDescriptionProducerInterceptor.beforeSend
(Producer<T> producer, Message<T> message) Deprecated.This is called fromsend(Object)
andsendAsync(Object)
methods, before send the message to the brokers.void
ProducerInterceptor.onSendAcknowledgement
(Producer<T> producer, Message<T> message, MessageId msgId, Throwable exception) Deprecated.This method is called when the message sent to the broker has been acknowledged, or when sending the message fails. -
Uses of Producer in org.apache.pulsar.client.api.interceptor
Methods in org.apache.pulsar.client.api.interceptor with parameters of type ProducerModifier and TypeMethodDescriptionProducerInterceptor.beforeSend
(Producer producer, Message message) This is called fromsend(Object)
andsendAsync(Object)
methods, before send the message to the brokers.ProducerInterceptorWrapper.beforeSend
(Producer producer, Message message) void
ProducerInterceptor.onSendAcknowledgement
(Producer producer, Message message, MessageId msgId, Throwable exception) This method is called when the message sent to the broker has been acknowledged, or when sending the message fails.void
ProducerInterceptorWrapper.onSendAcknowledgement
(Producer producer, Message message, MessageId msgId, Throwable exception)