- Sort Score
- Num 10 results
- Language All
Results 1 - 1 of 1 for NewProducer (0.04 seconds)
-
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 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0)