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