Uses of Interface
com.rabbitmq.stream.ProducerBuilder

Packages that use ProducerBuilder

Package	Description
com.rabbitmq.stream	Main API for RabbitMQ Stream Java Client.

Uses of ProducerBuilder in com.rabbitmq.stream

Methods in com.rabbitmq.stream that return ProducerBuilder

Modifier and Type	Method	Description
ProducerBuilder	ProducerBuilder.batchPublishingDelay(Duration batchPublishingDelay)	Period to send a batch of messages.
ProducerBuilder	ProducerBuilder.batchSize(int batchSize)	The maximum number of messages to accumulate before sending them to the broker.
ProducerBuilder	ProducerBuilder.compression(Compression compression)	Compression algorithm to use to compress a batch of sub-entries.
ProducerBuilder	ProducerBuilder.confirmTimeout(Duration timeout)	Time before the client calls the confirm callback to signal outstanding unconfirmed messages timed out.
ProducerBuilder	ProducerBuilder.dynamicBatch(boolean dynamicBatch)	Adapt batch size depending on ingress rate.
ProducerBuilder	ProducerBuilder.enqueueTimeout(Duration timeout)	Time before enqueueing of a message fail when the maximum number of unconfirmed is reached.
ProducerBuilder	ProducerBuilder.filterValue(Function<Message,String> filterValueExtractor)	Logic to extract a filter value from a message.
ProducerBuilder	ProducerBuilder.listeners(Resource.StateListener... listeners)	Add Resource.StateListeners to the producer.
ProducerBuilder	ProducerBuilder.maxUnconfirmedMessages(int maxUnconfirmedMessages)	The maximum number of unconfirmed outbound messages.
ProducerBuilder	ProducerBuilder.name(String name)	The producer name for deduplication (read the documentation before use).
ProducerBuilder	Environment.producerBuilder()	Create a ProducerBuilder to configure and create a Producer.
ProducerBuilder	ProducerBuilder.RoutingConfiguration.producerBuilder()	Go back to the producer builder.
ProducerBuilder	ProducerBuilder.retryOnRecovery(boolean retryOnRecovery)	Whether to republish unconfirmed messages after recovery.
ProducerBuilder	ProducerBuilder.stream(String stream)	The stream to send messages to.
ProducerBuilder	ProducerBuilder.subEntrySize(int subEntrySize)	The number of messages to put in a sub-entry of a publish frame.
ProducerBuilder	ProducerBuilder.superStream(String superStream)	The super stream to send messages to.