jerry-tao opened a new pull request #613:
URL: https://github.com/apache/rocketmq-client-go/pull/613
[ISSUE #568] Update lastPullTime use atomic.Value as same with
lastConsumeTime and lastLockTime
## What is the purpose of the change
[ISSUE #568] Update lastPullTime use atomic.Value as same with
lastConsumeTime and lastLockTime
## Brief changelog
[ISSUE #568] Update lastPullTime use atomic.Value as same with
lastConsumeTime and lastLockTime
## Verifying this change
```
func main() {
var nameSrv string
var group string
var topic string
c, _ := rocketmq.NewPushConsumer(
consumer.WithNameServer([]string{nameSrv}),
consumer.WithConsumerModel(consumer.Clustering),
consumer.WithGroupName(group),
)
_ = c.Subscribe(topic, consumer.MessageSelector{}, func(ctx
context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)
{
fmt.Printf("subscribe callback: %v \n", msgs)
return consumer.ConsumeSuccess, nil
})
c.Start()
n := make(chan os.Signal, 1)
signal.Notify(n, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM,
syscall.SIGINT, syscall.SIGSTOP)
<-n
}
```
```
go run -race consumer.go
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
