fix init delayed queue

rb-go · Jun 24, 2019 · ffc7a5b · ffc7a5b
1 parent 69386c4
commit ffc7a5b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -31,6 +31,7 @@ notifications:
 
 install:
   - go get -d
+  - go get -t -v
   - go get -u golang.org/x/lint/golint
   - go get -u golang.org/x/tools/cmd/goimports
   - go get -u golang.org/x/tools/cmd/cover

diff --git a/workercore.go b/workercore.go
@@ -150,6 +150,9 @@ func (wrk *Worker) initChannelQos() error {
 
 func (wrk *Worker) initDelayedQueue() error {
 	var err error
+	if wrk.config.DelayedQueueArguments == nil {
+		wrk.config.DelayedQueueArguments = make(map[string]interface{})
+	}
 	wrk.config.DelayedQueueArguments["x-dead-letter-exchange"] = ""
 	wrk.config.DelayedQueueArguments["x-dead-letter-routing-key"] = wrk.config.QueueName
 	wrk.amqpQueueDelayed, err = wrk.amqpChannel.QueueDeclare(