Skip to content

Commit f77f5ae

Browse files
committed
to_nsq: added async flag
1 parent c164c77 commit f77f5ae

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

apps/to_nsq/to_nsq.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import (
2323
var (
2424
topic = flag.String("topic", "", "NSQ topic to publish to")
2525
delimiter = flag.String("delimiter", "\n", "character to split input from stdin")
26+
async = flag.Bool("async", false, "use async mode (default false)")
2627

2728
destNsqdTCPAddrs = app.StringArray{}
2829
)
@@ -138,7 +139,12 @@ func readAndPublish(r *bufio.Reader, delim byte, producers map[string]*nsq.Produ
138139
}
139140

140141
for _, producer := range producers {
141-
err := producer.Publish(*topic, line)
142+
var err error
143+
if *async {
144+
err = producer.PublishAsync(*topic, line, nil, nil)
145+
} else {
146+
err = producer.Publish(*topic, line)
147+
}
142148
if err != nil {
143149
return err
144150
}

0 commit comments

Comments
 (0)