You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2025/03/15 16:24:34 UTC
(pulsar-client-go) branch master updated: [docs][producer] Update deliverAfter and deliverAt api comment (#1339)
This is an automated email from the ASF dual-hosted git repository.
zixuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new db5cb7ab [docs][producer] Update deliverAfter and deliverAt api comment (#1339)
db5cb7ab is described below
commit db5cb7ab4133dfa00e2bdfa67edbf98a294227d5
Author: zhou zhuohan <84...@qq.com>
AuthorDate: Sun Mar 16 00:24:28 2025 +0800
[docs][producer] Update deliverAfter and deliverAt api comment (#1339)
---
pulsar/message.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/pulsar/message.go b/pulsar/message.go
index 4e8d60d9..f965555e 100644
--- a/pulsar/message.go
+++ b/pulsar/message.go
@@ -56,14 +56,14 @@ type ProducerMessage struct {
// DeliverAfter requests to deliver the message only after the specified relative delay.
// Note: messages are only delivered with delay when a consumer is consuming
- // through a `SubscriptionType=Shared` subscription. With other subscription
- // types, the messages will still be delivered immediately.
+ // through a `SubscriptionType=Shared` or `SubscriptionType=KeyShared` subscription.
+ // With other subscription types, the messages will still be delivered immediately.
DeliverAfter time.Duration
// DeliverAt delivers the message only at or after the specified absolute timestamp.
// Note: messages are only delivered with delay when a consumer is consuming
- // through a `SubscriptionType=Shared` subscription. With other subscription
- // types, the messages will still be delivered immediately.
+ // through a `SubscriptionType=Shared` or `SubscriptionType=KeyShared` subscription.
+ // With other subscription types, the messages will still be delivered immediately.
DeliverAt time.Time
//Schema assign to the current message