Skip to content

Commit

Permalink
Merge pull request #576 from travis-ci/meat-amqp-setup-fix
Browse files Browse the repository at this point in the history
Do not dereference the AMQP job queue on error
  • Loading branch information
meatballhat authored Dec 16, 2018
2 parents a6071dd + e9823f1 commit 3723ceb
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions cli.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 3723ceb

Please sign in to comment.