diff --git a/pkg/event/amqp_producer.go b/pkg/event/amqp_producer.go
index dae71424..759d6e5a 100644
--- 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: