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

Merge remote-tracking branch 'monet/feat/offline-push' into fix-err

Browse Source
This commit is contained in:
icey-yu 2024-09-10 16:03:42 +08:00
commit f0aaf4f050
2 changed files with 3 additions and 2 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
} }