Worker client for beanstalkd. Written in Go by Yaron Sumel.
PR are welcome!
$ go get github.com/yaronsumel/beanWork
import "github.com/yaronsumel/beanWork"
bw := &beanWork.BeanWorker{"tcp4","127.0.0.1:11300"}
amountOfWorkers := 5
bw.Worker("mytube",amountOfWorkers,func(job *beanWork.BeanJob) {
//do some work here
job.Delete()
})
bw.Run()
* Recover from lost connections