blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-02 17:32:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: update OfflinePushConsumerHandler.

Browse Source
This commit is contained in:
Monet Lee 2024-09-10 16:00:27 +08:00
parent c5ea3f5abe
commit ad5c1c86cf
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/push/offlinepush_handler.go
View File

@ -22,9 +22,10 @@ type OfflinePushConsumerHandler struct {
offlinePusher offlinepush.OfflinePusher offlinePusher offlinepush.OfflinePusher
} }
func NewOfflinePushConsumerHandler(config *Config) (*OfflinePushConsumerHandler, error) { func NewOfflinePushConsumerHandler(config *Config, offlinePusher offlinepush.OfflinePusher) (*OfflinePushConsumerHandler, error) {
var offlinePushConsumerHandler OfflinePushConsumerHandler var offlinePushConsumerHandler OfflinePushConsumerHandler
var err error var err error
offlinePushConsumerHandler.offlinePusher = offlinePusher
offlinePushConsumerHandler.OfflinePushConsumerGroup, err = kafka.NewMConsumerGroup(config.KafkaConfig.Build(), config.KafkaConfig.ToOfflineGroupID, offlinePushConsumerHandler.OfflinePushConsumerGroup, err = kafka.NewMConsumerGroup(config.KafkaConfig.Build(), config.KafkaConfig.ToOfflineGroupID,
[]string{config.KafkaConfig.ToOfflinePushTopic}, true) []string{config.KafkaConfig.ToOfflinePushTopic}, true)
if err != nil { if err != nil {

2
internal/push/push.go
View File

@ -64,7 +64,7 @@ func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryReg
return err return err
} }
offlinePushConsumer, err := NewOfflinePushConsumerHandler(config) offlinePushConsumer, err := NewOfflinePushConsumerHandler(config, offlinePusher)
if err != nil { if err != nil {
return err return err
} }

2
internal/push/push_handler.go
View File

@ -257,7 +257,7 @@ func (c *ConsumerHandler) asyncOfflinePush(ctx context.Context, needOfflinePushU
if err := c.pushDatabase.MsgToOfflinePushMQ(ctx, conversationutil.GenConversationUniqueKeyForSingle(msg.SendID, msg.RecvID), needOfflinePushUserIDs, msg); err != nil { if err := c.pushDatabase.MsgToOfflinePushMQ(ctx, conversationutil.GenConversationUniqueKeyForSingle(msg.SendID, msg.RecvID), needOfflinePushUserIDs, msg); err != nil {
log.ZError(ctx, "Msg To OfflinePush MQ error", err, "needOfflinePushUserIDs", log.ZError(ctx, "Msg To OfflinePush MQ error", err, "needOfflinePushUserIDs",
needOfflinePushUserIDs, "msg", msg) needOfflinePushUserIDs, "msg", msg)
// prommetrics.SingleChatMsgProcessFailedCounter.Inc() prommetrics.SingleChatMsgProcessFailedCounter.Inc()
return return
} }
} }