Allow Config to be initialized without using Configure

.travis.yml

@@ -1,7 +1,7 @@
 language: go
 
 go:
-  - 1.7
+  - 1.11.1
 
 script:
   - go get github.com/customerio/gospec

config.go

@@ -4,11 +4,11 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 type config struct {
-	processId    string
+	ProcessId    string
 	Namespace    string
 	PollInterval int
 	Pool         *redis.Pool
@@ -73,8 +73,10 @@ func Configure(options map[string]string) {
 				return err
 			},
 		},
-		func(queue string) Fetcher {
-			return NewFetch(queue, make(chan *Msg), make(chan bool))
-		},
+		DefaultFetch,
 	}
 }
+
+func DefaultFetch(queue string) Fetcher {
+	return NewFetch(queue, make(chan *Msg), make(chan bool))
+}

config_test.go

@@ -31,14 +31,14 @@ func ConfigSpec(c gospec.Context) {
 	})
 
 	c.Specify("can specify custom process", func() {
-		c.Expect(Config.processId, Equals, "1")
+		c.Expect(Config.ProcessId, Equals, "1")
 
 		Configure(map[string]string{
 			"server":  "localhost:6379",
 			"process": "2",
 		})
 
-		c.Expect(Config.processId, Equals, "2")
+		c.Expect(Config.ProcessId, Equals, "2")
 	})
 
 	c.Specify("requires a server parameter", func() {

enqueue_test.go

@@ -5,7 +5,7 @@ import (
 
 	"github.com/customerio/gospec"
 	. "github.com/customerio/gospec"
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 func EnqueueSpec(c gospec.Context) {

fetch_test.go

@@ -3,7 +3,7 @@ package workers
 import (
 	"github.com/customerio/gospec"
 	. "github.com/customerio/gospec"
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 func buildFetch(queue string) Fetcher {

fetcher.go

@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 type Fetcher interface {
@@ -152,5 +152,5 @@ func (f *fetch) inprogressMessages() []string {
 }
 
 func (f *fetch) inprogressQueue() string {
-	return fmt.Sprint(f.queue, ":", Config.processId, ":inprogress")
+	return fmt.Sprint(f.queue, ":", Config.ProcessId, ":inprogress")
 }

manager_test.go

@@ -1,13 +1,14 @@
 package workers
 
 import (
-	"fmt"
+	"reflect"
+	"runtime"
 	"sync"
 	"time"
 
 	"github.com/customerio/gospec"
 	. "github.com/customerio/gospec"
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 type customMid struct {
@@ -54,7 +55,9 @@ func ManagerSpec(c gospec.Context) {
 
 		c.Specify("sets job function", func() {
 			manager := newManager("myqueue", testJob, 10)
-			c.Expect(fmt.Sprint(manager.job), Equals, fmt.Sprint(testJob))
+			expected := runtime.FuncForPC(reflect.ValueOf(manager.job).Pointer()).Name()
+			actual := runtime.FuncForPC(reflect.ValueOf(testJob).Pointer()).Name()
+			c.Expect(expected, Equals, actual)
 		})
 
 		c.Specify("sets worker concurrency", func() {

middleware_retry_test.go

@@ -3,7 +3,7 @@ package workers
 import (
 	"github.com/customerio/gospec"
 	. "github.com/customerio/gospec"
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 	"time"
 )
 

middleware_stats_test.go

@@ -3,7 +3,7 @@ package workers
 import (
 	"github.com/customerio/gospec"
 	. "github.com/customerio/gospec"
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 	"time"
 )
 

scheduled.go

@@ -4,7 +4,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 type scheduled struct {

scheduled_test.go

@@ -3,7 +3,7 @@ package workers
 import (
 	"github.com/customerio/gospec"
 	. "github.com/customerio/gospec"
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 func ScheduledSpec(c gospec.Context) {