From 09542d7176e0557ca6ff354b4d082c4cedb1aebc Mon Sep 17 00:00:00 2001
From: Xing Xing <mikespook@gmail.com>
Date: Mon, 3 Mar 2014 15:23:46 +0800
Subject: [PATCH] update examples

---
 example/worker/worker.go | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/example/worker/worker.go b/example/worker/worker.go
index 6b07e06..7474517 100644
--- a/example/worker/worker.go
+++ b/example/worker/worker.go
@@ -7,6 +7,7 @@ import (
 	"os"
 	"strings"
 	"time"
+	"net"
 )
 
 func ToUpper(job worker.Job) ([]byte, error) {
@@ -39,13 +40,15 @@ func main() {
 	defer w.Close()
 	w.ErrorHandler = func(e error) {
 		log.Println(e)
-		if e == worker.ErrLostConn {
-			proc, err := os.FindProcess(os.Getpid())
-			if err != nil {
-				log.Println(err)
-			}
-			if err := proc.Signal(os.Interrupt); err != nil {
-				log.Println(err)
+		if opErr, ok := e.(*net.OpError); ok {
+			if ! opErr.Temporary() {
+				proc, err := os.FindProcess(os.Getpid())
+				if err != nil {
+					log.Println(err)
+				}
+				if err := proc.Signal(os.Interrupt); err != nil {
+					log.Println(err)
+				}
 			}
 		}
 	}