- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for NewProducer (0.05 sec)
-
internal/event/target/nsq.go
if err := target.init(); err != nil { return false, err } return target.isActive() } func (target *NSQTarget) isActive() (bool, error) { if target.producer == nil { producer, err := nsq.NewProducer(target.args.NSQDAddress.String(), target.config) if err != nil { return false, err } target.producer = producer } if err := target.producer.Ping(); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 7.1K bytes - Viewed (0)