diff --git a/go.mod b/go.mod index 982606ac3..f0cd60304 100644 --- a/go.mod +++ b/go.mod @@ -15,7 +15,7 @@ require ( github.com/mitchellh/mapstructure v1.5.0 github.com/openimsdk/localcache v0.0.1 github.com/openimsdk/protocol v0.0.63 - github.com/openimsdk/tools v0.0.47-alpha.35 + github.com/openimsdk/tools v0.0.47-alpha.36 github.com/pkg/errors v0.9.1 // indirect github.com/prometheus/client_golang v1.18.0 github.com/stretchr/testify v1.9.0 diff --git a/go.sum b/go.sum index 126af67a1..702c3547f 100644 --- a/go.sum +++ b/go.sum @@ -270,8 +270,8 @@ github.com/openimsdk/gomake v0.0.5 h1:MxKVvhQRPBRhh7rzeu4+bBnqNjEEiX8gn0ojdfplW0 github.com/openimsdk/gomake v0.0.5/go.mod h1:PndCozNc2IsQIciyn9mvEblYWZwJmAI+06z94EY+csI= github.com/openimsdk/protocol v0.0.63 h1:9DnweZe9nEYDFa4fGTbC9Cqi0gLUdtBhRo1NRP2X3WQ= github.com/openimsdk/protocol v0.0.63/go.mod h1:OZQA9FR55lseYoN2Ql1XAHYKHJGu7OMNkUbuekrKCM8= -github.com/openimsdk/tools v0.0.47-alpha.35 h1:uR5GBZqpR7tltXa8pfjwWlXTgNYqIt/90bR7ygeGT/k= -github.com/openimsdk/tools v0.0.47-alpha.35/go.mod h1:P4oGP1Pd+d4ctbLD5U/XQTgl8yu8Hd3skx640Fr69ko= +github.com/openimsdk/tools v0.0.47-alpha.36 h1:r3WmAObA/UcAvJwtuuJZwcKAyFjwzEQVNt0dh/TD7bY= +github.com/openimsdk/tools v0.0.47-alpha.36/go.mod h1:P4oGP1Pd+d4ctbLD5U/XQTgl8yu8Hd3skx640Fr69ko= github.com/pelletier/go-toml/v2 v2.1.0 h1:FnwAJ4oYMvbT/34k9zzHuZNrhlz48GB3/s6at6/MHO4= github.com/pelletier/go-toml/v2 v2.1.0/go.mod h1:tJU2Z3ZkXwnxa4DPO899bsyIoywizdUvyaeZurnPPDc= github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ= diff --git a/internal/msgtransfer/online_history_msg_handler.go b/internal/msgtransfer/online_history_msg_handler.go index 43f4622a8..dad64037d 100644 --- a/internal/msgtransfer/online_history_msg_handler.go +++ b/internal/msgtransfer/online_history_msg_handler.go @@ -415,6 +415,7 @@ func (och *OnlineHistoryRedisConsumerHandler) ConsumeClaim( for { select { case <-ticker.C: + log.ZDebug(context.Background(), "ticker update", "length", len(messages)) // if the buffer is empty and running is false, return loop. if len(messages) == 0 { if !running.Load() {