Queues duplication

queues_flag.go

@@ -15,6 +15,7 @@ var (
 type queuesFlag []string
 
 func (q *queuesFlag) Set(value string) error {
+	*q = queuesFlag{}
 	for _, queueAndWeight := range strings.Split(value, ",") {
 		if queueAndWeight == "" {
 			continue

queues_flag_test.go

@@ -79,8 +79,8 @@ var queuesFlagSetTests = []struct {
 }
 
 func TestQueuesFlagSet(t *testing.T) {
+	actual := new(queuesFlag)
 	for _, tt := range queuesFlagSetTests {
-		actual := new(queuesFlag)
 		err := actual.Set(tt.v)
 		if fmt.Sprint(actual) != fmt.Sprint(tt.expected) {
 			t.Errorf("QueuesFlag: set to %s expected %v, actual %v", tt.v, tt.expected, actual)

worker_test.go

@@ -1,6 +1,7 @@
 package goworker
 
 import (
+	"flag"
 	"reflect"
 	"testing"
 )
@@ -51,9 +52,10 @@ func TestEnqueue(t *testing.T) {
 		},
 	}
 
-	workerSettings.Queues = []string{queueName}
-	workerSettings.UseNumber = true
-	workerSettings.ExitOnComplete = true
+	flag.Set("exit-on-complete", "true")
+	flag.Set("queues", queueName)
+	flag.Set("concurrency", "1")
+	flag.Set("use-number", "true")
 
 	err := Enqueue(expectedJob)
 	if err != nil {