diff --git a/d4-goclient.go b/d4-goclient.go index ca9fc68..f2eea1d 100644 --- a/d4-goclient.go +++ b/d4-goclient.go @@ -412,7 +412,7 @@ func setReaderWriters(d4 *d4S) bool { logger.Println("Could not connect to d4 Redis") return false } - (*d4).src, err = inputreader.NewLPOPReader(&(*d4).redisCon, (*d4).conf.redisDB, (*d4).conf.redisQueue, int(time.Second*(*d4).retry)) + (*d4).src, err = inputreader.NewLPOPReader(&(*d4).redisCon, (*d4).conf.redisDB, (*d4).conf.redisQueue) if err != nil { log.Printf("Could not create d4 Redis Descriptor %q \n", err) return false diff --git a/go.mod b/go.mod index a8992bc..5faa39e 100644 --- a/go.mod +++ b/go.mod @@ -3,6 +3,6 @@ module github.com/D4-project/d4-goclient go 1.13 require ( - github.com/D4-project/d4-golang-utils v0.1.4 + github.com/D4-project/d4-golang-utils v0.1.5 github.com/gomodule/redigo v2.0.0+incompatible ) diff --git a/go.sum b/go.sum index 9f7ae39..1f1f174 100644 --- a/go.sum +++ b/go.sum @@ -1,5 +1,8 @@ github.com/D4-project/d4-golang-utils v0.1.3 h1:JrGoQ3Va4SwGl8Pjnb2bK/wxdFaGsjulAmp0bxZO7jg= github.com/D4-project/d4-golang-utils v0.1.3/go.mod h1:GGR5KMhvABZtIfmS5jZkwQnBoP+9/V0ZEETSGiWLaM4= +github.com/D4-project/d4-golang-utils v0.1.4/go.mod h1:GGR5KMhvABZtIfmS5jZkwQnBoP+9/V0ZEETSGiWLaM4= +github.com/D4-project/d4-golang-utils v0.1.5 h1:0aL2gv0uc56Gn2NwQY8L2C6OQRdq0LpoioAeLWs6zZc= +github.com/D4-project/d4-golang-utils v0.1.5/go.mod h1:GGR5KMhvABZtIfmS5jZkwQnBoP+9/V0ZEETSGiWLaM4= github.com/gofrs/uuid v3.2.0+incompatible h1:y12jRkkFxsd7GpqdSZ+/KCs/fJbqpEXSGd4+jfEaewE= github.com/gofrs/uuid v3.2.0+incompatible/go.mod h1:b2aQJv3Z4Fp6yNu3cdSllBxTCLRxnplIgP/c0N/04lM= github.com/gomodule/redigo v2.0.0+incompatible h1:K/R+8tc58AaqLkqG2Ol3Qk+DR/TlNuhuh457pBFPtt0=