diff --git a/service/runway/server/main.go b/service/runway/server/main.go index dc9985001..f95a9bf97 100644 --- a/service/runway/server/main.go +++ b/service/runway/server/main.go @@ -146,7 +146,7 @@ func run() error { } defer mysqlQueue.Close() - logger.Info("initialized queue", zap.String("dsn", queueDSN)) + logQueueInitialized(logger) subscriberName := os.Getenv("HOSTNAME") if subscriberName == "" { @@ -305,6 +305,12 @@ func run() error { return err } +const queueBackendMySQL = "mysql" + +func logQueueInitialized(logger *zap.Logger) { + logger.Info("initialized queue", zap.String("backend", queueBackendMySQL)) +} + // newMergerFactory builds the mergers for the server. // // MERGER pins every queue to one implementation explicitly, which is how a test