diff --git a/cmd/runmqserver/main.go b/cmd/runmqserver/main.go index 703043d..4885ce4 100644 --- a/cmd/runmqserver/main.go +++ b/cmd/runmqserver/main.go @@ -170,12 +170,29 @@ func doMain() error { } } + enableTraceCrtmqm := os.Getenv("MQ_ENABLE_TRACE_CRTMQM") + if enableTraceCrtmqm == "true" || enableTraceCrtmqm == "1" { + err = startMQTrace() + if err != nil { + logTermination(err) + return err + } + } + newQM, err := createQueueManager(name, *devFlag) if err != nil { logTermination(err) return err } + if enableTraceCrtmqm == "true" || enableTraceCrtmqm == "1" { + err = endMQTrace() + if err != nil { + logTermination(err) + return err + } + } + var wg sync.WaitGroup defer func() { log.Debug("Waiting for log mirroring to complete")