From e9823f1ae8298ca29c38642a995da825667de6f5 Mon Sep 17 00:00:00 2001 From: Dan Buch Date: Sun, 16 Dec 2018 04:58:44 -0500 Subject: [PATCH] Do not dereference the AMQP job queue on error --- cli.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/cli.go b/cli.go index 26ef2b02d..5bcb2948a 100644 --- a/cli.go +++ b/cli.go @@ -671,14 +671,14 @@ func (i *CLI) buildAMQPJobQueueAndCanceller() (*AMQPJobQueue, *AMQPCanceller, er jobQueue, err := NewAMQPJobQueue(amqpConn, i.Config.QueueName, i.Config.StateUpdatePoolSize, i.Config.RabbitMQSharding) - // Set the consumer priority directly instead of altering the signature of - // NewAMQPJobQueue :sigh_cat: - jobQueue.priority = i.Config.AmqpConsumerPriority - if err != nil { return nil, nil, err } + // Set the consumer priority directly instead of altering the signature of + // NewAMQPJobQueue :sigh_cat: + jobQueue.priority = i.Config.AmqpConsumerPriority + jobQueue.DefaultLanguage = i.Config.DefaultLanguage jobQueue.DefaultDist = i.Config.DefaultDist jobQueue.DefaultGroup = i.Config.DefaultGroup