Merge pull request #118 from pinpt/add-rabbitmqbits

jmull3n · web-flow · commit f529a75a967b · 2020-10-21T18:25:01.000-05:00
move back to no-wait true when cancelling a subscription; don't need to wait since it's an ackable queue
diff --git a/rabbitmq/rabbitmq.go b/rabbitmq/rabbitmq.go
@@ -254,7 +254,7 @@ func (session *Session) startConsumeLoop(consumergroup string, autoAck bool, exc
 
 			err := session.consumerchannelhost.Channel.Cancel(
 				consumergroup, // Consumer
-				false,          // No-Wait
+				true,          // No-Wait
 			)
 			if err != nil {
 				log.Error(session.logger, "error closing channel on exit", "err", err)

Original file line number	Diff line number	Diff line change
`@@ -254,7 +254,7 @@ func (session *Session) startConsumeLoop(consumergroup string, autoAck bool, exc`
`254`	`254`
`255`	`255`	`err := session.consumerchannelhost.Channel.Cancel(`
`256`	`256`	`consumergroup, // Consumer`
`257`		`- false, // No-Wait`
	`257`	`+ true, // No-Wait`
`258`	`258`	`)`
`259`	`259`	`if err != nil {`
`260`	`260`	`log.Error(session.logger, "error closing channel on exit", "err", err)`