This commit is contained in:
Minh Nguyen 2022-03-26 06:24:03 +07:00
parent 1d5422dd35
commit d9484e28ca
2 changed files with 7 additions and 3 deletions

View File

@ -42,7 +42,10 @@ func NewClient(config Config) (*Client, error) {
} }
// Init schedule // Init schedule
initSchedule() if config.IsScheduled {
initSchedule()
}
return client, nil return client, nil
} }

View File

@ -4,6 +4,7 @@ import "github.com/Selly-Modules/natsio"
// Config ... // Config ...
type Config struct { type Config struct {
Redis RedisCfg Redis RedisCfg
Nats natsio.Config Nats natsio.Config
IsScheduled bool
} }