Skip to content

Instantly share code, notes, and snippets.

@kiasaki

kiasaki/stack.txt

Created April 26, 2015 01:57
Show Gist options
  • Save kiasaki/ade57e60204e91e448aa to your computer and use it in GitHub Desktop.
Save kiasaki/ade57e60204e91e448aa to your computer and use it in GitHub Desktop.
Download ZIP
Raw
stack.txt
2015/04/25 21:57:22 INF 1 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 2 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 3 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 4 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 6 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 7 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 ERR 5 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 5 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 5 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 INF 8 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 9 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 10 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 11 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 12 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 13 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 14 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 15 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 16 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 17 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 18 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 19 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 20 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 21 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 22 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 23 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 24 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 25 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 26 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 27 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 28 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 29 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 INF 30 (127.0.0.1:4160) connecting to nsqd
2015/04/25 21:57:22 ERR 25 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 25 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 25 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 25 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 25 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 25 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 25 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 1 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 1 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 1 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 1 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 1 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 2 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 2 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 2 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 2 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 2 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 3 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 3 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 3 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 3 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 3 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 3 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 3 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 4 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 4 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 4 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 4 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 4 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 4 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 4 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 26 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 26 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 26 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 26 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 26 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 27 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 27 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 27 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 27 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 27 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 27 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 27 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 28 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 28 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 28 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 28 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 28 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 29 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 29 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 29 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 29 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 29 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 29 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 29 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 30 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 30 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 30 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 30 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 30 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 30 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 30 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 6 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 6 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 6 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 6 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 6 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 6 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 6 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 7 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 7 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 7 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 7 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 7 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 7 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 7 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 8 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 8 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 8 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 8 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 8 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 8 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 8 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 9 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 9 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 9 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 9 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 9 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 9 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 9 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 10 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 10 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 10 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 10 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 10 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 11 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 11 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 11 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 11 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 11 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 11 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 11 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 12 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 12 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 12 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 12 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 12 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 12 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 12 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 13 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 13 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 13 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 13 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 13 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 13 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 13 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 14 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 14 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 14 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 14 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 14 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 14 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 14 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 15 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 15 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 15 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 15 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 15 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 16 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 16 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 16 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 16 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 16 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 17 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 17 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 17 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 17 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 17 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 17 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 17 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 18 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 18 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 18 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 18 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 18 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 18 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 18 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 19 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 19 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 19 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 19 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 19 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 19 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 19 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 20 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 20 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 20 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 20 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 20 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 21 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 21 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 21 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 21 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 21 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 21 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 21 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 22 (127.0.0.1:4160) IO error - read tcp 127.0.0.1:4160: connection reset by peer
2015/04/25 21:57:22 INF 22 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 22 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 22 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 22 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 22 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 22 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 23 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 23 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 23 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 23 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 23 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 24 (127.0.0.1:4160) IO error - EOF
2015/04/25 21:57:22 INF 24 (127.0.0.1:4160) beginning close
2015/04/25 21:57:22 INF 24 (127.0.0.1:4160) readLoop exiting
2015/04/25 21:57:22 INF 24 (127.0.0.1:4160) breaking out of writeLoop
2015/04/25 21:57:22 INF 24 (127.0.0.1:4160) writeLoop exiting
2015/04/25 21:57:22 ERR 24 (127.0.0.1:4160) IO error - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 ERR 24 (127.0.0.1:4160) sending command - write tcp 127.0.0.1:4160: broken pipe
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) finished draining, cleanup exiting
2015/04/25 21:57:22 INF 5 (127.0.0.1:4160) clean close complete
2015/04/25 21:57:22 INF 5 exiting router
panic: not connected
goroutine 1 [running]:
main.main()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:132 +0xc78
goroutine 5 [chan receive]:
main.func·002()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:80 +0xc5
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:92 +0x799
goroutine 6 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805a200, 0xc208040500, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805a200, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x43c, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 7 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805a400, 0xc2080405f0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805a400, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x40e, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 8 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805a600, 0xc208040690, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805a600, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x426, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 9 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805a800, 0xc208040730, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805a800, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x46e, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 11 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805ae00, 0xc208040870, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805ae00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x4d4, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 12 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805b000, 0xc208040d20, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805b000, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x41a, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 13 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805b200, 0xc208040eb0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805b200, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x43e, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 14 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805b400, 0xc208040f50, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805b400, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x402, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 15 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805b600, 0xc208041040, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805b600, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x402, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 16 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805b800, 0xc208041130, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805b800, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x41a, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 17 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805ba00, 0xc208041220, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805ba00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x432, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 18 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805bc00, 0xc208041310, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805bc00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x492, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 19 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20805be00, 0xc208041400, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20805be00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x3f6, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 20 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0ce000, 0xc2080414f0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0ce000, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x432, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 21 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0ce200, 0xc2080415e0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0ce200, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x46d, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 22 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0ce400, 0xc2080416d0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0ce400, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x44a, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 23 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0ce600, 0xc2080417c0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0ce600, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x402, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 24 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0ce800, 0xc2080418b0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0ce800, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x487, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 25 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cea00, 0xc2080419a0, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cea00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x4ab, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 26 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cec00, 0xc208041a90, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cec00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x489, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 27 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cee00, 0xc208041b80, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cee00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x40e, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 28 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cf000, 0xc208041c70, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cf000, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x43d, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 29 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cf200, 0xc208041d60, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cf200, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x431, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 30 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cf400, 0xc208041e50, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cf400, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x41a, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 31 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cf600, 0xc208041f40, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cf600, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x40e, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 32 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cf800, 0xc20a106050, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cf800, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x401, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 33 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cfc00, 0xc20a106140, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cfc00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x473, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 34 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a0cfe00, 0xc20a106230, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a0cfe00, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x402, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 35 [chan receive]:
github.com/bitly/go-nsq.(*Producer).sendCommand(0xc20a116000, 0xc20a106320, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:205 +0xf7
github.com/bitly/go-nsq.(*Producer).Publish(0xc20a116000, 0x7fff5fbff6d3, 0xc, 0xc209094000, 0x41a, 0x1000000, 0x0, 0x0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:185 +0x1d7
main.func·003()
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:108 +0x247
created by main.main
/Users/kiasaki/code/go/src/github.com/kiasaki/bdm-hack-2015/bson_to_nsq/main.go:116 +0x8af
goroutine 61 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805a3d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 62 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208031200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 45 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cf400)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 65 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208031440)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 64 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805a5d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 48 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805a200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 68 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc2080317a0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 67 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805a7d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 51 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805a400)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 71 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc2080318c0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 70 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805a9d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 54 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805a600)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 88 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cf9d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 89 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec7e0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 57 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805a800)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 58 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cf5d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 59 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec5a0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 60 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec698)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec5a0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 63 [semacquire]:
sync.(*WaitGroup).Wait(0xc2080312f8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208031200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 66 [semacquire]:
sync.(*WaitGroup).Wait(0xc208031538)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208031440)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 69 [semacquire]:
sync.(*WaitGroup).Wait(0xc208031898)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc2080317a0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 72 [semacquire]:
sync.(*WaitGroup).Wait(0xc2080319b8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc2080318c0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 75 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cf600)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 92 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec900)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 91 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cfdd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 78 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cf800)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 95 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0eca20)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 94 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cffd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 81 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cfc00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 164 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208080d80)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 163 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805b1d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 84 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cfe00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 85 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cf7d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 86 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec6c0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 87 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec7b8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec6c0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 90 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec8d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec7e0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 93 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec9f8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec900)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 96 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ecb18)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0eca20)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 99 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a116000)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 100 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a1161d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 101 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ecb40)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 102 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ecc38)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ecb40)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 105 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805ae00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 167 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 166 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805b3d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 108 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805b000)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 170 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081320)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 169 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805b5d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 111 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805b200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 173 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081440)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 172 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805b7d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 114 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805b400)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 176 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081560)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 175 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805b9d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 117 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805b600)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 179 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081680)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 178 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805bbd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 120 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805b800)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 182 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc2080817a0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 181 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805bdd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 123 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805ba00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 185 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc2080818c0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 184 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805bfd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 126 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805bc00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 188 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc2080819e0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 187 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ce1d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 129 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20805be00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 191 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081b00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 190 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ce3d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 132 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0ce000)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 194 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081c20)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 193 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ce5d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 135 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0ce200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 197 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081d40)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 196 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ce7d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 138 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0ce400)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 200 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208081e60)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 199 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ce9d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 141 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0ce600)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 203 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec000)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 202 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cebd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 144 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0ce800)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 206 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec120)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 205 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cedd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 147 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cea00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 209 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec240)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 208 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cefd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 150 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cec00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 212 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec360)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 211 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cf1d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 153 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cee00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 215 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc20a0ec480)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 214 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0cf3d8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 156 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cf000)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 159 [select]:
github.com/bitly/go-nsq.(*Producer).router(0xc20a0cf200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:290 +0x6bf
created by github.com/bitly/go-nsq.(*Producer).connect
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:270 +0x781
goroutine 160 [semacquire]:
sync.(*WaitGroup).Wait(0xc20805afd8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.func·010()
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:283 +0x3e
created by github.com/bitly/go-nsq.(*Producer).close
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/producer.go:285 +0xf4
goroutine 161 [select]:
github.com/bitly/go-nsq.(*Conn).cleanup(0xc208031b00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:645 +0x510
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:629 +0xd8
goroutine 162 [semacquire]:
sync.(*WaitGroup).Wait(0xc208031bf8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208031b00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 165 [semacquire]:
sync.(*WaitGroup).Wait(0xc208080e78)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208080d80)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 168 [semacquire]:
sync.(*WaitGroup).Wait(0xc2080812f8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081200)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 171 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081418)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081320)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 174 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081538)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081440)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 177 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081658)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081560)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 180 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081778)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081680)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 183 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081898)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc2080817a0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 186 [semacquire]:
sync.(*WaitGroup).Wait(0xc2080819b8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc2080818c0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 189 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081ad8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc2080819e0)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 192 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081bf8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081b00)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 195 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081d18)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081c20)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 198 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081e38)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081d40)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 201 [semacquire]:
sync.(*WaitGroup).Wait(0xc208081f58)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc208081e60)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 204 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec0f8)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec000)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 207 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec218)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec120)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 210 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec338)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec240)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 213 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec458)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec360)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
goroutine 216 [semacquire]:
sync.(*WaitGroup).Wait(0xc20a0ec578)
/usr/local/go/src/sync/waitgroup.go:132 +0x169
github.com/bitly/go-nsq.(*Conn).waitForCleanup(0xc20a0ec480)
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:679 +0x3b
created by github.com/bitly/go-nsq.func·003
/Users/kiasaki/code/go/src/github.com/bitly/go-nsq/conn.go:631 +0xf5
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment