pkg/event: Fix waitResult logic in producer

livepeer · Nov 14, 2022 · c6aa7ae · c6aa7ae
1 parent 147c919
commit c6aa7ae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/event/amqp_producer.go b/pkg/event/amqp_producer.go
@@ -94,7 +94,7 @@ func (p *amqpProducer) Publish(ctx context.Context, msg AMQPMessage) error {
 	}
 	select {
 	case p.publishQ <- publish:
-		return nil
+		break // continue below
 	case <-ctx.Done():
 		return ctx.Err()
 	case <-p.shutdownStart: