Fix issue in beanstalk backoff

rustatian · rustatian · commit 00d8ff7768b8 · 2020-03-20T15:51:56.000+03:00
diff --git a/.gitignore b/.gitignore
@@ -6,4 +6,6 @@ vendor/
 clover.xml
 .DS_Store
 tests/.rr-test.yml
-go.sum
+go.sum
+psr-worker.php
+.rr-sample.yaml
diff --git a/broker/beanstalk/conn.go b/broker/beanstalk/conn.go
@@ -138,9 +138,7 @@ func (cn *conn) watch(network, addr string) {
 			if err != nil {
 				fmt.Println(fmt.Sprintf("redial failed: %s", err.Error()))
 				cn.dead <- nil
-				return
 			}
-			continue
 
 		case <-cn.stop:
 			cn.lock.L.Lock()

Original file line number	Diff line number	Diff line change
`@@ -138,9 +138,7 @@ func (cn *conn) watch(network, addr string) {`
`138`	`138`	`if err != nil {`
`139`	`139`	`fmt.Println(fmt.Sprintf("redial failed: %s", err.Error()))`
`140`	`140`	`cn.dead <- nil`
`141`		`- return`
`142`	`141`	`}`
`143`		`- continue`
`144`	`142`
`145`	`143`	`case <-cn.stop:`
`146`	`144`	`cn.lock.L.Lock()`