Fix lint.

Ron Cemer · Ron Cemer · commit 394cea98f160 · 2025-07-01T13:03:48.000-04:00
diff --git a/rabbitmq/broker.go b/rabbitmq/broker.go
@@ -204,7 +204,6 @@ func (br *Broker) Receive() ([]byte, error) {
 	broker.Move2back(br.queues, queue)
 
 	var err error
-    var delivery <-chan amqp.Delivery
 
 	delivery, delivery_exists := br.delivery[queue]
 	if !delivery_exists {
@@ -226,7 +225,7 @@ func (br *Broker) Receive() ([]byte, error) {
 	}
 
 	select {
-	case msg := <-br.delivery[queue]:
+	case msg := <-delivery:
 		if br.rawMode {
 			return msg.Body, nil
 		}

Original file line number	Diff line number	Diff line change
`@@ -204,7 +204,6 @@ func (br *Broker) Receive() ([]byte, error) {`
`204`	`204`	`broker.Move2back(br.queues, queue)`
`205`	`205`
`206`	`206`	`var err error`
`207`		`- var delivery <-chan amqp.Delivery`
`208`	`207`
`209`	`208`	`delivery, delivery_exists := br.delivery[queue]`
`210`	`209`	`if !delivery_exists {`
`@@ -226,7 +225,7 @@ func (br *Broker) Receive() ([]byte, error) {`
`226`	`225`	`}`
`227`	`226`
`228`	`227`	`select {`
`229`		`- case msg := <-br.delivery[queue]:`
	`228`	`+ case msg := <-delivery:`
`230`	`229`	`if br.rawMode {`
`231`	`230`	`return msg.Body, nil`
`232`	`231`	`}`