nsq success logs

nsq_to_file.log

merlin.local ~> $ nsq_to_file  --nsqd-tcp-address=127.0.0.1:4150 --topic=test
2012/12/20 21:00:09 starting AsyncHandler go-routine
2012/12/20 21:00:09 [127.0.0.1:4150] connecting to nsqd
2012/12/20 21:00:09 old  new test.merlin.2012-12-20_21.log
2012/12/20 21:00:09 opening /tmp/test.merlin.2012-12-20_21.log
2012/12/20 21:00:09 syncing 1 records to disk
2012/12/20 21:00:39 syncing 51 records to disk
2012/12/20 21:00:39 [127.0.0.1:4150] received heartbeat from nsqd

nsqd.log

merlin.local ~> $ nsqlookupd 
2012/12/20 20:57:31 nsqlookupd v0.2.15
2012/12/20 20:57:31 TCP: listening on [::]:4160
2012/12/20 20:57:31 HTTP: listening on [::]:4161
2012/12/20 20:57:35 TCP: new client(127.0.0.1:57317)
2012/12/20 20:57:35 CLIENT(127.0.0.1:57317): desired protocol 538990129
2012/12/20 20:57:35 CLIENT(127.0.0.1:57317) registered TCP:4150 HTTP:4151 address:merlin.local
2012/12/20 20:57:35 DB: client(127.0.0.1:57317) added registration for topic:test
2012/12/20 20:57:50 CLIENT(127.0.0.1:57317): pinged (last ping 15.001359s)
2012/12/20 20:58:05 CLIENT(127.0.0.1:57317): pinged (last ping 15.000665s)
2012/12/20 20:58:20 CLIENT(127.0.0.1:57317): pinged (last ping 14.999445s)
2012/12/20 20:58:35 CLIENT(127.0.0.1:57317): pinged (last ping 15.000046s)
2012/12/20 20:58:50 CLIENT(127.0.0.1:57317): pinged (last ping 15.000117s)
2012/12/20 20:59:05 CLIENT(127.0.0.1:57317): pinged (last ping 15.000189s)
2012/12/20 20:59:20 CLIENT(127.0.0.1:57317): pinged (last ping 14.99952s)
2012/12/20 20:59:35 CLIENT(127.0.0.1:57317): pinged (last ping 14.999654s)
2012/12/20 20:59:50 CLIENT(127.0.0.1:57317): pinged (last ping 14.999994s)
2012/12/20 21:00:05 CLIENT(127.0.0.1:57317): pinged (last ping 15.000469s)
2012/12/20 21:00:09 DB: client(127.0.0.1:57317) added registration for channel:nsq_to_file in topic:test
2012/12/20 21:00:09 DB: client(127.0.0.1:57317) added registration for topic:test
2012/12/20 21:00:20 CLIENT(127.0.0.1:57317): pinged (last ping 15.000768s)
2012/12/20 21:00:35 CLIENT(127.0.0.1:57317): pinged (last ping 14.999637s)

nsqlookupd.log

merlin.local ~> $ nsqd --lookupd-tcp-address=localhost:4160
2012/12/20 20:57:35 nsqd v0.2.15
2012/12/20 20:57:35 worker id 737
2012/12/20 20:57:35 TOPIC(test): created
2012/12/20 20:57:35 DISKQUEUE(test): readOne() opened test.diskqueue.000000.dat
2012/12/20 20:57:35 TCP: listening on [::]:4150
2012/12/20 20:57:35 LOOKUP: adding peer localhost:4160
2012/12/20 20:57:35 LOOKUP connecting to localhost:4160
2012/12/20 20:57:35 HTTP: listening on [::]:4151
2012/12/20 20:57:35 LOOKUPD(localhost:4160): peer info {TcpPort:4160 HttpPort:4161 Version:0.2.15 Address:merlin.local}
2012/12/20 20:57:35 LOOKUPD(localhost:4160): REGISTER test
2012/12/20 20:57:50 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:58:05 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:58:20 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:58:35 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:58:50 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:59:05 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:59:20 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:59:35 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 20:59:50 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 21:00:05 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 21:00:09 TCP: new client(127.0.0.1:57414)
2012/12/20 21:00:09 CLIENT(127.0.0.1:57414): desired protocol 538990130
2012/12/20 21:00:09 TOPIC(test): new channel(nsq_to_file)
2012/12/20 21:00:09 LOOKUPD(localhost:4160): channel REGISTER test nsq_to_file
2012/12/20 21:00:20 LOOKUPD(localhost:4160): sending heartbeat
2012/12/20 21:00:35 LOOKUPD(localhost:4160): sending heartbeat