- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for NewProducer (0.08 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.1K bytes - Viewed (0)