smol fix
This commit is contained in:
2
main.go
2
main.go
@ -31,7 +31,6 @@ func main() {
|
|||||||
// Initialize Redis client
|
// Initialize Redis client
|
||||||
redisClient, redisError := adapters.NewRedisClient()
|
redisClient, redisError := adapters.NewRedisClient()
|
||||||
|
|
||||||
adapters.RedisClient = redisClient
|
|
||||||
|
|
||||||
// Initialize pubsub
|
// Initialize pubsub
|
||||||
var pubSub pubsub.PubSub
|
var pubSub pubsub.PubSub
|
||||||
@ -40,6 +39,7 @@ func main() {
|
|||||||
lib.LogWarning.Printf("\n[PUBSUB/INIT] Falling back to LocalPubSub\n")
|
lib.LogWarning.Printf("\n[PUBSUB/INIT] Falling back to LocalPubSub\n")
|
||||||
pubSub = &adapters.LocalPubSub{}
|
pubSub = &adapters.LocalPubSub{}
|
||||||
} else {
|
} else {
|
||||||
|
adapters.RedisClient = redisClient
|
||||||
pubSub = &adapters.RedisPubSub{
|
pubSub = &adapters.RedisPubSub{
|
||||||
Client: adapters.RedisClient,
|
Client: adapters.RedisClient,
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user