Fixed pubsub errors
This commit is contained in:
parent
9e5da7a63b
commit
82c585e4fb
1 changed files with 1 additions and 2 deletions
|
@ -2,7 +2,6 @@ package adapters
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"errors"
|
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
"atri.dad/lib"
|
"atri.dad/lib"
|
||||||
|
@ -33,7 +32,7 @@ func NewRedisClient() (*redis.Client, error) {
|
||||||
opts, err := redis.ParseURL(redis_url)
|
opts, err := redis.ParseURL(redis_url)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.New("math: square root of negative number")
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
lib.LogInfo.Printf("\n[PUBSUB/REDIS]Connecting to Redis at %s\n", opts.Addr)
|
lib.LogInfo.Printf("\n[PUBSUB/REDIS]Connecting to Redis at %s\n", opts.Addr)
|
||||||
|
|
Loading…
Add table
Reference in a new issue