clean_queue.go

package main

import (
	"github.com/kr/beanstalk"
)

func main() {
	var id uint64
	c, err := beanstalk.Dial("tcp", "127.0.0.1:11300")
	if err != nil {
		panic(err)
	}
	for err == nil {
		if id, _, err = c.Reserve(1e9); err == nil {
			err = c.Delete(id)
		}
	}
}