beanstalk example in go

consumer.go

package main

import (
        "fmt"
        "github.com/kr/beanstalk"
        "os"
        "time"
)

func main() {
        c, err := beanstalk.Dial("tcp", "127.0.0.1:11300")
        if err != nil {
                fmt.Println("Error connection beanstalkd: ", err)
                os.Exit(1)
        }
        defer c.Close()

        for {
                id, body, err := c.Reserve(5 * time.Hour)
                if err != nil {
                        fmt.Println("Error on reserve: ", err)
                } else {
                        fmt.Printf("id: %d, body: %s\n", id, body)
                }
        }
}

provider.go

package main

import (
        "fmt"
        "github.com/kr/beanstalk"
        "os"
        "time"
)

func main() {
        c, err := beanstalk.Dial("tcp", "127.0.0.1:11300")
        if err != nil {
                fmt.Println("Error connection beanstalkd: ", err)
                os.Exit(1)
        }
        defer c.Close()

        for {
                t := time.Now().String()
                id, err := c.Put([]byte(t), 1, 0, 120*time.Second)
                if err != nil {
                        fmt.Printf("Error using put: %s\n", err)
                } else {
                        fmt.Printf("id: %d, body: %s \n", id, t)
                }
                time.Sleep(time.Second)
        }
}