nsq_pub.go

func start(host string) {
	pub := NewNSQPeer(host)
	for i := 0; i < 1000; i++ {
		message := getMessage()
		pub.Send(message)
	}
	pub.Teardown()
}

nsq_sub.go

func start(host string) {
	sub := NewNSQPeer(host)
	sub.Subscribe()
	for {
		message, _ := sub.Recv()
		fmt.Println(message)
		if isDone() {
			break
		}
	}
	sub.Teardown()
}