package main

import (
	"github.com/soyking/local-nsq"
	"sync"
)

var wg sync.WaitGroup

func intCallback(v interface{}) {
	println(v.(int))
	wg.Done()
}

func main() {
	l := lnsq.NewLocalNSQ()
	wg.Add(1)
	l.Subscribe("channel", "topic", intCallback, 1, 1)
	l.Dispatch("channel", 17)
	wg.Wait()
}