func NotifySubscribers()

in services/redis-updater/services/persistence/store_data.go [53:67]

• 11 lines of code
• 2 McCabe index (conditional complexity)

func NotifySubscribers(msg model.Message, client redis.Client, channel string) error {

	msgBytes, err := json.Marshal(msg)

	if err != nil {
		fmt.Println("Error marshalling data:")
		fmt.Println(err.Error())
	}

	msgString := string(msgBytes)
	client.Publish(channel, msgString)
	fmt.Println("Publishing to subscribers: " + msgString)

	return err
}