Uses of Interface
org.apache.pulsar.client.api.TypedMessageBuilder
Packages that use TypedMessageBuilder
-
Uses of TypedMessageBuilder in org.apache.pulsar.client.api
Methods in org.apache.pulsar.client.api that return TypedMessageBuilderModifier and TypeMethodDescriptionTypedMessageBuilder.deliverAfter
(long delay, TimeUnit unit) Request to deliver the message only after the specified relative delay.TypedMessageBuilder.deliverAt
(long timestamp) Deliver the message only at or after the specified absolute timestamp.TypedMessageBuilder.disableReplication()
Disable geo-replication for this message.TypedMessageBuilder.eventTime
(long timestamp) Set the event time for a given message.Sets the key of the message for routing policy.TypedMessageBuilder.keyBytes
(byte[] key) Sets the bytes of the key of the message for routing policy.Configure theTypedMessageBuilder
from a config map, as an alternative compared to call the individual builder methods.Producer.newMessage()
Create a new message builder.<V> TypedMessageBuilder
<V> Producer.newMessage
(Schema<V> schema) Create a new message builder with schema, not required same parameterized type with the producer.Producer.newMessage
(Transaction txn) Create a new message builder with transaction.TypedMessageBuilder.orderingKey
(byte[] orderingKey) Sets the ordering key of the message for message dispatch inSubscriptionType.Key_Shared
mode.TypedMessageBuilder.properties
(Map<String, String> properties) Add all the properties in the provided map.Sets a new property on a message.TypedMessageBuilder.replicationClusters
(List<String> clusters) Override the geo-replication clusters for this message.TypedMessageBuilder.sequenceId
(long sequenceId) Specify a custom sequence id for the message being published.Set a domain object on the message.