Skip to content

Instantly share code, notes, and snippets.

@craigbeck

craigbeck/gist:4349721

Created December 21, 2012 00:02
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save craigbeck/4349721 to your computer and use it in GitHub Desktop.
Save craigbeck/4349721 to your computer and use it in GitHub Desktop.
Download ZIP
NSQ output when nsq_to_file cannot connect to nsqd
Raw
gistfile1.txt
merlin.local ~> $ nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161
2012/12/20 15:42:16 starting AsyncHandler go-routine
2012/12/20 15:42:16 lookupd addr 127.0.0.1:4161
2012/12/20 15:42:16 LOOKUPD: querying http://127.0.0.1:4161/lookup?topic=test
2012/12/20 15:42:16 [merlin.local:4150] connecting to nsqd
2012/12/20 15:42:17 ERROR: failed to connect to nsqd (merlin.local:4150) - dial tcp merlin.local:4150: i/o timeout
2012/12/20 15:42:46 old new test.merlin.2012-12-20_15.log
2012/12/20 15:42:46 opening /tmp/test.merlin.2012-12-20_15.log
2012/12/20 15:44:20 LOOKUPD: querying http://127.0.0.1:4161/lookup?topic=test
2012/12/20 15:44:20 [merlin.local:4150] connecting to nsqd
2012/12/20 15:44:21 ERROR: failed to connect to nsqd (merlin.local:4150) - dial tcp merlin.local:4150: i/o timeout
2012/12/20 15:46:20 LOOKUPD: querying http://127.0.0.1:4161/lookup?topic=test
2012/12/20 15:46:20 [merlin.local:4150] connecting to nsqd
2012/12/20 15:46:21 ERROR: failed to connect to nsqd (merlin.local:4150) - dial tcp merlin.local:4150: i/o timeout
2012/12/20 15:48:20 LOOKUPD: querying http://127.0.0.1:4161/lookup?topic=test
Raw
gistfile2.txt
merlin.local ~> $ nsqd --lookupd-tcp-address=localhost:4160
2012/12/20 15:42:22 nsqd v0.2.15
2012/12/20 15:42:22 worker id 737
2012/12/20 15:42:22 TOPIC(test): created
2012/12/20 15:42:22 DISKQUEUE(test): readOne() opened test.diskqueue.000000.dat
2012/12/20 15:42:22 LOOKUP: adding peer localhost:4160
2012/12/20 15:42:22 LOOKUP connecting to localhost:4160
2012/12/20 15:42:22 TCP: listening on [::]:4150
2012/12/20 15:42:22 HTTP: listening on [::]:4151
2012/12/20 15:42:22 LOOKUPD(localhost:4160): peer info {TcpPort:4160 HttpPort:4161 Version:0.2.15 Address:merlin.local}
2012/12/20 15:42:22 LOOKUPD(localhost:4160): REGISTER test
2012/12/20 15:42:37 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:42:52 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:43:07 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:43:22 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:43:37 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:43:52 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:44:07 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:44:22 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:44:25 TCP: new client(127.0.0.1:55642)
2012/12/20 15:44:37 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:44:52 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:45:07 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:45:22 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:45:37 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:45:52 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:46:07 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:46:22 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:46:25 TCP: new client(127.0.0.1:55770)
2012/12/20 15:46:37 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:46:52 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:47:07 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:47:16 ERROR: failed to read protocol version - EOF
2012/12/20 15:47:16 ERROR: failed to read protocol version - EOF
2012/12/20 15:47:22 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:47:37 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 15:47:52 LOOKUPD(localhost:4160): sending heartbeat
Raw
gistfile3.txt
merlin.local ~> $ nsqlookupd
2012/12/20 15:17:18 nsqlookupd v0.2.15
2012/12/20 15:17:18 TCP: listening on [::]:4160
2012/12/20 15:17:18 HTTP: listening on [::]:4161
2012/12/20 15:17:46 TCP: new client(127.0.0.1:53789)
2012/12/20 15:17:46 CLIENT(127.0.0.1:53789): desired protocol 538990129
2012/12/20 15:17:46 CLIENT(127.0.0.1:53789) registered TCP:4150 HTTP:4151 address:merlin.local
2012/12/20 15:18:01 CLIENT(127.0.0.1:53789): pinged (last ping 15.001489s)
2012/12/20 15:18:16 CLIENT(127.0.0.1:53789): pinged (last ping 14.999603s)
2012/12/20 15:18:31 CLIENT(127.0.0.1:53789): pinged (last ping 15.00019s)
2012/12/20 15:18:46 CLIENT(127.0.0.1:53789): pinged (last ping 15.000144s)
2012/12/20 15:19:01 CLIENT(127.0.0.1:53789): pinged (last ping 15.000011s)
2012/12/20 15:19:16 CLIENT(127.0.0.1:53789): pinged (last ping 14.999976s)
2012/12/20 15:19:31 CLIENT(127.0.0.1:53789): pinged (last ping 14.99917s)
... snipped ...
2012/12/20 15:41:47 CLIENT(127.0.0.1:55010): pinged (last ping 15.000115s)
2012/12/20 15:42:02 CLIENT(127.0.0.1:55010): pinged (last ping 14.999964s)
2012/12/20 15:42:17 CLIENT(127.0.0.1:55010): pinged (last ping 15.000026s)
2012/12/20 15:42:21 CLIENT(127.0.0.1:55010): closing
2012/12/20 15:42:21 ERROR: client(127.0.0.1:55010) - EOF
2012/12/20 15:42:22 TCP: new client(127.0.0.1:55425)
2012/12/20 15:42:22 CLIENT(127.0.0.1:55425): desired protocol 538990129
2012/12/20 15:42:22 CLIENT(127.0.0.1:55425) registered TCP:4150 HTTP:4151 address:merlin.local
2012/12/20 15:42:22 DB: client(127.0.0.1:55425) added registration for topic:test
2012/12/20 15:42:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.00126s)
2012/12/20 15:42:52 CLIENT(127.0.0.1:55425): pinged (last ping 15.000058s)
2012/12/20 15:43:07 CLIENT(127.0.0.1:55425): pinged (last ping 15.000038s)
2012/12/20 15:43:22 CLIENT(127.0.0.1:55425): pinged (last ping 15.000053s)
2012/12/20 15:43:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.000034s)
2012/12/20 15:43:52 CLIENT(127.0.0.1:55425): pinged (last ping 14.999854s)
2012/12/20 15:44:07 CLIENT(127.0.0.1:55425): pinged (last ping 15.00005s)
2012/12/20 15:44:22 CLIENT(127.0.0.1:55425): pinged (last ping 15.000086s)
2012/12/20 15:44:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.000019s)
2012/12/20 15:44:52 CLIENT(127.0.0.1:55425): pinged (last ping 15.000043s)
2012/12/20 15:45:07 CLIENT(127.0.0.1:55425): pinged (last ping 14.999784s)
2012/12/20 15:45:22 CLIENT(127.0.0.1:55425): pinged (last ping 14.999903s)
2012/12/20 15:45:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.000013s)
2012/12/20 15:45:52 CLIENT(127.0.0.1:55425): pinged (last ping 14.999979s)
2012/12/20 15:46:07 CLIENT(127.0.0.1:55425): pinged (last ping 15.000037s)
2012/12/20 15:46:22 CLIENT(127.0.0.1:55425): pinged (last ping 14.99994s)
2012/12/20 15:46:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.000053s)
2012/12/20 15:46:52 CLIENT(127.0.0.1:55425): pinged (last ping 14.999631s)
2012/12/20 15:47:07 CLIENT(127.0.0.1:55425): pinged (last ping 15.000613s)
2012/12/20 15:47:22 CLIENT(127.0.0.1:55425): pinged (last ping 14.999555s)
2012/12/20 15:47:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.00042s)
2012/12/20 15:47:52 CLIENT(127.0.0.1:55425): pinged (last ping 15.000023s)
2012/12/20 15:48:07 CLIENT(127.0.0.1:55425): pinged (last ping 14.999902s)
2012/12/20 15:48:22 CLIENT(127.0.0.1:55425): pinged (last ping 14.999964s)
2012/12/20 15:48:37 CLIENT(127.0.0.1:55425): pinged (last ping 15.000127s)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment