listen_on_channel.go

	ch := make(chan *nats.Msg, 64)
	_, err = nc.ChanSubscribe("insights.get.velocity", ch)
	if err != nil {
		panic(err)
	}

	go func() {
		for {
			msg := <-ch
			fmt.Print("Receiving in channel: ")
			fmt.Println(string(msg.Data))
		}
	}()

c := make(chan os.Signal, 1)
	signal.Notify(c, syscall.SIGINT)
	go func() {
		// Wait for signal
		<-c
		nc.Drain()
		os.Exit(0)
	}()
	runtime.Goexit()