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 theTypedMessageBuilderfrom 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_Sharedmode.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.