This is an automated email from the ASF dual-hosted git repository.
wenfeng pushed a commit to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/native by this push:
new 08cdb4e feat: rename persistent with interval (#359)
08cdb4e is described below
commit 08cdb4e728c452c050c56862c527b934f245cbe4
Author: xujianhai666 <[email protected]>
AuthorDate: Fri Jan 3 16:31:26 2020 +0800
feat: rename persistent with interval (#359)
Closes #358
---
internal/client.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/internal/client.go b/internal/client.go
index fec61fd..e566797 100644
--- a/internal/client.go
+++ b/internal/client.go
@@ -48,7 +48,7 @@ const (
_HeartbeatBrokerInterval = 30 * time.Second
// Offset persistent interval for consumer
- _PersistOffset = 5 * time.Second
+ _PersistOffsetInterval = 5 * time.Second
// Rebalance interval
_RebalanceInterval = 20 * time.Second
@@ -320,7 +320,7 @@ func (c *rmqClient) Start() {
// schedule persist offset
go func() {
- ticker := time.NewTicker(_PersistOffset)
+ ticker := time.NewTicker(_PersistOffsetInterval)
defer ticker.Stop()
for {
select {
