Skip to content

Commit 56b09a3

Browse files
committed
add --redis-address
1 parent 64794c9 commit 56b09a3

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

main.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,15 @@ const Usage = `
1717
--topic name --publish name [--channel name]
1818
[--max-attempts n] [--max-in-flight n]
1919
[--lookupd-http-address addr...]
20+
[--redis-address addr]
2021
[--level name]
2122
2223
nsq_to_redis -h | --help
2324
nsq_to_redis --version
2425
2526
Options:
2627
--lookupd-http-address addr nsqlookupd addresses [default: :4161]
28+
--redis-address addr redis address [default: :6379]
2729
--max-attempts n nsq max message attempts [default: 5]
2830
--max-in-flight n nsq messages in-flight [default: 250]
2931
--publish name   redis channel template
@@ -62,7 +64,7 @@ func main() {
6264

6365
redis := redis.NewClient(&redis.Options{
6466
Network: "tcp",
65-
Addr: ":6379",
67+
Addr: args["--redis-address"].(string),
6668
DialTimeout: 10 * time.Second,
6769
})
6870

0 commit comments

Comments
 (0)