bskexample.go

package main

import (
  "bytes"
	"encoding/gob"
	"github.com/kr/beanstalk"
	"fmt"
)

type Message struct {
	Action string
	Args   []string
}

func main() {
	buf := new(bytes.Buffer)
	m := Message{
		Action: "regenerate-apprc",
		Args:   []string{"myapp"},
	}
	err := gob.NewEncoder(buf).Encode(m)
	if err != nil {
		panic(err)
	}
	c, err := beanstalk.Dial("tcp", "127.0.0.1:11300")
	if err != nil {
		panic(err)
	}
	defer c.Close()
	id, err := c.Put(buf.Bytes(), 1, 0, 120e9)
	if err != nil {
		panic(err)
	}
	fmt.Println(id)
	id, body, err := c.Reserve(1e9)
	if err != nil {
		panic(err)
	}
	fmt.Println(id)
	buf = bytes.NewBuffer(body)
	err = gob.NewDecoder(buf).Decode(&m)
	if err != nil {
		panic(err)
	}
	fmt.Println(m)
	fmt.Println(c.Delete(id))
}